Package rx.internal.producers
package rx.internal.producers
-
ClassesClassDescriptionProducer that allows changing an underlying producer atomically and correctly resume with the accumulated requests.Producer that serializes any event emission with requesting and producer changes.Producer that holds an unbounded (or custom) queue, handles terminal events, enqueues values and relays them to a child subscriber on request.Producer that holds an unbounded (or custom) queue to enqueue values and relays them to a child subscriber on request.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).A producer which emits a single value and completes the child on the first positive request.