Packages that use Producer

• Uses of Producer in rx

  Methods in rx with parameters of type Producer

  Modifier and Type	Method and Description
  void	Subscriber.setProducer(Producer p) If other subscriber is set (by calling constructor Subscriber.Subscriber(Subscriber) or Subscriber.Subscriber(Subscriber, boolean)) then this method calls setProducer on the other subscriber.

• Uses of Producer in rx.internal.producers

  Classes in that implement

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

  Methods in rx.internal.producers with parameters of type Producer

  Modifier and Type	Method and Description
  void	ProducerObserverArbiter.setProducer(Producer p)
  void	ProducerArbiter.setProducer(Producer newProducer)

• Uses of Producer in rx.internal.util

  Classes in rx.internal.util that implement Producer

  Modifier and Type	Class and Description
  class	BackpressureDrainManager Manages the producer-backpressure-consumer interplay by matching up available elements with requested elements and/or terminal events.