Abstract interface for a "sink" accepting multiple entire streams.
A consumer can accept a number of consequtive streams using addStream, and when no further data need to be added, the close method tells the consumer to complete its work and shut down.
This class is not just a Sink
because it is also combined with
other Sink classes, like it's combined with EventSink in the
StreamSink class.
The Stream.pipe accepts a StreamConsumer
and will pass the stream
to the consumer's addStream method. When that completes, it will
call close and then complete its own returned future.
- Implemented by
Constructors
Properties
- hashCode → int
-
Get a hash code for this object.…
read-only, inherited - runtimeType → Type
-
A representation of the runtime type of the object.
read-only, inherited
Operators
-
operator ==(
other) → bool -
The equality operator.…
inherited
Methods
-
addStream(
Stream<S> stream) → Future -
Consumes the elements of
stream
.… -
close(
) → Future -
Tells the consumer that no futher streams will be added.…
-
noSuchMethod(
Invocation invocation) → dynamic -
noSuchMethod is invoked when users invoke a non-existent method on an object. The name of the method and the arguments of the invocation are passed to noSuchMethod in an Invocation. If noSuchMethod returns a value, that value becomes the result of the original invocation.…
inherited -
toString(
) → String -
Returns a string representation of this object.
inherited