NonBlockingChannel<T>.fromStream constructor

NonBlockingChannel<T>.fromStream(
  1. Stream<T> stream
)

Implementation

factory NonBlockingChannel.fromStream(Stream<T> stream) {
  final ret = NonBlockingChannel.fromStream(stream);
  ret.pipe(stream);
  return ret;
}