主张流从流中发出的所有物品，直到在DART中取消？

Question

是否有任何方便的方法来断言由流发出的所有项目，直到取消？

如果我使用：

expectLater(
  stream,
  emitsInOrder(<String>[
    'item1',
    'item2',
  ]),
);

并且流 emits ['item1'，'item2'，'item3']，测试不会失败。

到目前为止，我发现的唯一方法是以下内容：

var count = 0;
final expected = ['item1', 'item2', 'item3'];
stream.listen(
  expectAsync1(
    (final result) {
      expect(result, expected[count++]);
    },
    count: expected.length,
  ),
);

但是它有点冗长，而且不容易阅读。有一种更简单/更优雅的方式吗？

Answer 1

emitsdone emitsdone 如果<<代码>流在某个时候关闭。

例如：

test('Test', () async {
  final controller = StreamController<String>();
  final stream = controller.stream;
  final matcher = expectLater(
    stream,
    emitsInOrder(<dynamic>[
      'Item1',
      'Item2',
      emitsDone,
    ]),
  );
  controller
    ..add('Item1')
    ..add('Item2')
    ..add('Item3')
    ..close();
  await matcher;
  await controller.close();
});

该测试失败了错误：

Expected: should do the following in order:
          • emit an event that 'Item1'
          • emit an event that 'Item2'
          • be done
  Actual: <Instance of '_ControllerStream<String>'>
   Which: emitted • Item1
                  • Item2
                  • Item3
                  x Stream closed.
            which didn't be done

正如@IRN所建议的，在某个时候完成的流 s的更紧凑的替代方法是使用tolist：

test('Test', () async {
  final controller = StreamController<String>();
  final stream = controller.stream;
  final matcher = expectLater(stream.toList(), completion(<String>['Item1', 'Item2']));
  controller
    ..add('Item1')
    ..add('Item2')
    ..add('Item3')
    ..close();
  await matcher;
  await controller.close();
});

如果streamstream < /code>永远不会关闭，您可以添加超时并检查那个时期内发出的项目：

test('Test3', () async {
  final controller = StreamController<String>();
  final stream = controller.stream.timeout(const Duration(milliseconds: 200));
  final matcher = expectLater(
    stream,
    emitsInOrder(<dynamic>[
      'Item1',
      'Item2',
    ]),
  );
  controller
    ..add('Item1')
    ..add('Item2');
  await matcher;
  await controller.close();
});

Answer 2

tolist将项目收集到列表中

await expectLater(stream.toList(), completion(expected));

您可以使用 （但是，什么都没有，您只需要等待超时）即可。

在所有事件发出之前，它不会捕获错误，emitsinorder方法对此更好。不过，不短。