ForwardingSink<T, R> class
abstract
A Sink that supports event hooks.
This makes it suitable for certain rx transformers that need to take action after onListen, onPause, onResume or onCancel.
The ForwardingSink has been designed to handle asynchronous events from
Streams. See, for example, Stream.eventTransformed which uses
EventSinks to transform events.
Constructors
Properties
- hashCode → int
-
The hash code for this object.
no setterinherited
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
Methods
-
add(
EventSink< R> sink, T data) → void - Handle data event
-
addError(
EventSink< R> sink, Object error, [StackTrace? st]) → void - Handle error event
-
close(
EventSink< R> sink) → void - Handle close event
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
onCancel(
EventSink< R> sink) → FutureOr - Fires when a subscriber cancels.
-
onListen(
EventSink< R> sink) → void - Fires when a listener subscribes on the underlying Stream.
-
onPause(
EventSink< R> sink) → void - Fires when a subscriber pauses.
-
onResume(
EventSink< R> sink) → void - Fires when a subscriber resumes after a pause.
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited