Stream<T> bind(Stream<S> stream)

Transform the incoming stream's events.

Creates a new stream. When this stream is listened to, it will start listening on stream, and generate events on the new stream based on the events from stream.

Subscriptions on the returned stream should propagate pause state to the subscription on stream.

Source 

Stream<T> bind(Stream<S> stream) {
  return new Stream<T>.eventTransformed(
      stream,
      (EventSink sink) => new _ConverterStreamEventSink(this, sink));
}