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