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/*<String>*/ bind(Stream/*<String>*/ stream) { return new Stream<String>.eventTransformed( stream, (EventSink<String> sink) => new _LineSplitterEventSink(sink)); }