changeStream method

  1. @override
StreamChannel<OperationMessage> changeStream(
  1. Stream<OperationMessage> change(
    1. Stream<OperationMessage>
    )
)
inherited

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

Implementation

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