如何在 Dart 中对 Stream.listen() 进行单元测试

Question

考虑下面的测试代码...

main() {
  StreamController controller;
  setUp(() {
    controller = StreamController.broadcast(sync: false);
  });

  tearDown(() {
    controller.close();
  });

  test('Stream listen test', () {
    var stream = controller.stream;

    stream.listen((event) {
      // >>>>> How can I test if this was called?? <<<<<<
    });

    controller.add('Here is an event!');
  });
}

...测试stream.listen(...) 回调被调用的正确方法是什么？

stream.listen(...) 不返回 Future，因此传统的 expectAsyncX 样式匹配器在这里不起作用。

也许有一些方法可以使用stream.listen(...)返回的StreamSubscription.asFuture()？

Answer 1

您可以使用expectLater 函数等待来自您的Stream 的async 响应，并使用emits 将您的Stream 与您发出的值进行比较，如下所示：

  test('Stream listen test', () {
    var stream = controller.stream;

    final String value = 'Here is an event!';

    stream.listen((event) {
      // >>>>> How can I test if this was called?? <<<<<<
    });

    expectLater(stream, emits(value));

    controller.add(value);
  });

更新

您可以在listen 方法中尝试expectAsync1，如果没有发出任何值，则会触发超时。

stream.listen(
      expectAsync1(
        (event) {
          expect(event, value);
        },
      ),
    );