in lib/src/stream_queue.dart [954:960]
bool update(QueueList<Result<T>> events, bool isDone) {
while (_eventsSent < events.length) {
events[_eventsSent++].addTo(_controller);
}
if (isDone && !_controller.isClosed) _controller.close();
return transaction._committed || transaction._rejected;
}