A object that accepts stream events both synchronously and asynchronously.

A StreamSink unifies the asynchronous methods from StreamConsumer and the synchronous methods from EventSink.

The EventSink methods can't be used while the addStream is called. As soon as the addStream's Future completes with a value, the EventSink methods can be used again.

If addStream is called after any of the EventSink methods, it'll be delayed until the underlying system has consumed the data added by the EventSink methods.

When EventSink methods are used, the done Future can be used to catch any errors.

When close is called, it will return the done Future.

Implements
Implemented by

Constructors

StreamSink()

Properties

done Future

Return a future which is completed when the StreamSink is finished.

read-only
hashCode int

The 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

close() Future

Tells the stream sink that no further streams will be added.

add(S event) → void

Send a data event to a stream.

inherited
addError(Object errorEvent, [ StackTrace stackTrace ]) → void

Send an async error to a stream.

inherited
addStream(Stream<S> stream) Future

Consumes the elements of stream.

inherited
noSuchMethod(Invocation invocation) → dynamic

Invoked when a non-existent method or property is accessed.

inherited
toString() String

Returns a string representation of this object.

inherited