等待關於流繼續

Question

簡單鏢問題之前，脈衝x1時，得到了一個流

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