changeSink method

@override StreamChannel<Object?> changeSink(StreamSink<Object?> change(StreamSink<Object?>))

Returns a copy of this with sink replaced by change's return value.

Implementation

@override
StreamChannel<T> changeSink(StreamSink<T> Function(StreamSink<T>) change) =>
    StreamChannel.withCloseGuarantee(stream, change(sink));