changeSink method

  1. @override
StreamChannel<T> changeSink (
  1. StreamSink<T> change(
    1. StreamSink<T> sink
    )
)
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));