The target of a Stream.pipe call.

The Stream.pipe call will pass itself to this object, and then return the resulting Future. The pipe should complete the future when it's done.

Implemented by

Constructors

StreamConsumer()

Methods

addStream(Stream<S> stream) → Future

Consumes the elements of stream.…

close() → Future

Tell the consumer that no futher streams will be added.…