next method
Implementation
Future<StreamDelivery<S>> next() {
// Host state can change before an owner-queued notification reaches Dart.
_checkSignals();
final read = Completer<StreamDelivery<S>>();
_reads.add(read);
_advance();
return read.future;
}