Pipes the events of this stream into
All events of this stream are added to
streamConsumer is closed when this stream has been successfully added
to it - when the future returned by
addStream completes without an error.
Returns a future which completes when this stream has been consumed and the consumer has been closed.
@override AsObservableFuture<dynamic> pipe(StreamConsumer<T> streamConsumer) => AsObservableFuture<dynamic>(_stream.pipe(streamConsumer));