EsStreamControllerImpl
Description
An implementation base class for an <EsStreamController> controls a stream that only supports a single controller.
Instance State
• state: `' Current state of the controller
• onListen: `' 0-arg, no expected return type. Could be nil
• onCancel: `' 0-arg, answers EsFuture. Could be nil
• onPause: `' 0-arg, no expected return type. Could be nil
• onResume: `' 0-arg, no expected return type. Could be nil
• doneFuture: `' Future completed when the stream sends its last event.
• varData: <Object>' or nil. Field containing different data depending on the current subscription state. Ifstateis EsStateInitial, the field may contain an' for events added to the controller before a subscription. While state is EsStateSubscribed, the field contains the subscription. When state is EsStateCanceledthe 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: 04/21/2022