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