pipe method

  1. @override
void pipe(
  1. StreamChannel<OperationMessage> other
)
inherited

Connects this to other, so that any values emitted by either are sent directly to the other.

Implementation

@override
void pipe(StreamChannel<T> other) {
  stream.pipe(other.sink);
  other.stream.pipe(sink);
}