在流上使用Distinct似乎无法过滤出相同的结果

问题描述

请看一下这段代码=>

void main() async {
  Stream<int> _intStream() async* {
    for (int i = 0; i < 10; i++) yield i;
  }

  Stream<int> _even() => _intStream().where((int i) => i % 2 == 0);
  Stream<bool> _isEven(Stream<int> stream) => stream.map((int i) => i % 2 == 0);

  print('test 1: should print 5 [true] and 5 [false] alternate');
  await for (bool b in _isEven(_intStream())) {
    print('test 1: $b');
  }

  print('test 2: should print 5 [true]');
  await for (bool b in _isEven(_even())) {
    print('test 2: $b');
  }

  print('test 3: should print ONLY ONE [true]');
  await for (bool b in _isEven(_even().distinct())) {
    print('test 3: $b');
  }
}

我以错误的方式使用distinct()吗？

先谢谢您

解决方法

没关系，我只是在错误的地方放了不同， 以下作品符合预期

void main() async {
  Stream<int> _intStream() async* {
    for (int i = 0; i < 10; i++) yield i;
  }

  Stream<int> _even() => _intStream().where((int i) => i % 2 == 0);
  Stream<bool> _isEven(Stream<int> stream) => stream.map((int i) => i % 2 == 0);

  print('test 1: should print 5 [true] and 5 [false] alternate');
  await for (bool b in _isEven(_intStream())) {
    print('test 1: $b');
  }

  print('test 2: should print 5 [true]');
  await for (bool b in _isEven(_even())) {
    print('test 2: $b');
  }

  print('test 3: should print ONLY ONE [true]');
  await for (bool b in _isEven(_even()).distinct()) {
    print('test 3: $b');
  }
}