Class | Description |
---|---|
ProducerArbiter |
Producer that allows changing an underlying producer atomically and correctly resume with the accumulated
requests.
|
ProducerObserverArbiter<T> |
Producer that serializes any event emission with requesting and producer changes.
|
QueuedProducer<T> |
Producer that holds an unbounded (or custom) queue, handles terminal events,
enqueues values and relays them to a child subscriber on request.
|
QueuedValueProducer<T> |
Producer that holds an unbounded (or custom) queue to enqueue values and relays them
to a child subscriber on request.
|
SingleDelayedProducer<T> |
Producer that emits a single value and completes the child subscriber once that
single value is set on it and the child requested items (maybe both asynchronously).
|
SingleProducer<T> |
A producer which emits a single value and completes the child on the first positive request.
|
Copyright © 2017. All rights reserved.