in lib/src/stream_queue.dart [792:808]
bool update(QueueList<Result<T>> events, bool isDone) {
while (_list.length < _eventsToTake) {
if (events.isEmpty) {
if (isDone) break;
return false;
}
var event = events.removeFirst();
if (event.isError) {
event.asError!.complete(_completer);
return true;
}
_list.add(event.asValue!.value);
}
_completer.complete(_list);
return true;
}