forwarding_stream library Null safety

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