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
<details> onListen:onPause:onResume:onCancel:
</details>
Instance Methods
<details> add:
Send or enqueue a data event.
</details>
<details> addError:stackTrace:
Send or enqueue a data event.
</details>
<details> addStream:cancelOnError:
</details>
<details> close
</details>
<details> done
<pre><code> 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.
</code></pre> </details>
<details> hasListener
<pre><code> Whether there is an active listener.
Answers:
<Boolean>
</code></pre> </details>
<details> isClosed
</details>
<details> isPaused
</details>
<details> onListen
</details>
<details> onPause
</details>
<details> onResume
</details>
<details> sink
Answer this object since it exposes the <EsStreamSink> interface
</details>
<details> stream
<pre><code> Answer a new stream every time. The streams are equal, but not identical.
Answers:
<EsControllerStream>
</code></pre> </details>
Last modified date: 04/21/2022