Package rx.internal.producers

Class Summary

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.