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

Question

简单的dart问题，得到一个流

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();