在继续之前等待流脉冲 x 时间

Question

简单的飞镖问题，得到一个流

Stream<Event>

我在单元测试中订阅。想要这样的东西：

stream.listen(listener)
await listenerBeenNotified5Times
expect(result,expectation)

我知道 expectAsync 可用于确保通知发生 5 次，但我想等到流式传输 5 个事件后暂停执行。

Answer 1

var s = stream.take(5);
var subscription = s.listen(listener);
await susciption.asFuture;

或

await stream.take(5).toList();