rxdart/forwarding_stream library

Functions

forwardStream<T, R>(Stream<T> stream, ForwardingSink<T, R> connectedSink) → Stream<R>

@private Helper method which forwards the events from an incoming Stream to a new StreamController. It captures events such as onListen, onPause, onResume and onCancel, which can be used in pair with a ForwardingSink