in lib/src/stream_queue.dart [747:764]
bool update(QueueList<Result<T>> events, bool isDone) {
while (_eventsToSkip > 0) {
if (events.isEmpty) {
if (isDone) break;
return false;
}
_eventsToSkip--;
var event = events.removeFirst();
if (event.isError) {
_completer.completeError(
event.asError!.error, event.asError!.stackTrace);
return true;
}
}
_completer.complete(_eventsToSkip);
return true;
}