stream method

@override Stream<T> stream()

Implementation

@override
Stream<T> stream() async* {
  while (true) {
    switch (await recv()) {
      case RecvOk<T>(value: final v):
        yield v;
      case RecvError(isDisconnected: true):
        return;
      default:
        // Ignore other errors (like empty/timeout if they were to happen)
        break;
    }
  }
}