changeSink method
- StreamSink<
T> change(- StreamSink<
T> sink
- StreamSink<
override
Returns a copy of this with sink
replaced by change
's return
value.
Implementation
@override
StreamChannel<T> changeSink(StreamSink<T> change(StreamSink<T> sink)) =>
StreamChannel.withCloseGuarantee(stream, change(sink));