stream method

  1. @override
Stream<T> stream()
inherited

Returns a Stream of values ending once RecvError$Disconnected is yielded.

Implementation

@override
Stream<T> stream() async* {
  while (true) {
    final rec = await recv();
    switch (rec) {
      case Ok(v: final ok):
        yield ok;
      case Err(v: final err):
        switch (err) {
          case RecvError$Disconnected():
            return;
          default:
        }
    }
  }
}