pipe method

void pipe (StreamChannel<T> other)

override

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

Implementation

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