| Modifier and Type | Class and Description |
|---|---|
| public class | ProducerArbiter
Producer that allows changing an underlying producer atomically and correctly resume with the accumulated requests. |
| public class | ProducerObserverArbiter<
the value type T>Producer that serializes any event emission with requesting and producer changes. |
| public class | QueuedProducer<
the value type T>Producer that holds an unbounded (or custom) queue, handles terminal events, enqueues values and relays them to a child subscriber on request. |
| public class | QueuedValueProducer<
the value type T>Producer that holds an unbounded (or custom) queue to enqueue values and relays them to a child subscriber on request. |
| public class | SingleDelayedProducer<
the value type 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). |
| public class | SingleProducer<
the value type T>A producer which emits a single value and completes the child on the first positive request. |