EsStreamControllerImpl
Description
An implementation base class for an <EsStreamController> controls a stream that only supports a single controller.
Instance State
-
state: `<Integer>' Current state of the controller
-
onListen: `<Block>' 0-arg, no expected return type. Could be nil
-
onCancel: `<Block>' 0-arg, answers EsFuture. Could be nil
-
onPause: `<Block>' 0-arg, no expected return type. Could be nil
-
onResume: `<Block>' 0-arg, no expected return type. Could be nil
-
doneFuture: `<EsFuture>' Future completed when the stream sends its last event.
-
varData: `<Object>' or nil. Field containing different data depending on the current subscription state.
If state is EsStateInitial, the field may contain an <EsPendingEvents>' for events added to the controller before a
subscription. While state is EsStateSubscribed, the field contains the subscription. When state is EsStateCanceled
the field is currently not used, and will contain nil`.
Class Methods
onListen:onPause:onResume:onCancel:
No comment
Instance Methods
add:
Send or enqueue a data event.
addError:stackTrace:
Send or enqueue a data event.
addStream:cancelOnError:
No comment
done
Returns a future that is completed when the stream is done
processing events.
This happens either when the done event has been sent, or if the
subscriber of a single-subscription stream is cancelled.
hasListener
Whether there is an active listener.
Answers:
<Boolean>
sink
Answer this object since it exposes the <EsStreamSink> interface
stream
Answer a new stream every time. The streams are equal, but not identical.
Answers:
<EsControllerStream>
Last modified date: 12/27/2024