Uses of Interface
rx.Producer

Packages that use Producer

Package	Description
rx	Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.internal.producers
rx.internal.util
rx.observables	Classes extending the Observable base reactive class, synchronous and asynchronous event generators.
rx.subjects	Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables).

Uses of Producer in rx

Fields in rx declared as Producer

Modifier and Type	Field	Description
private Producer	Subscriber.producer

Methods in rx with parameters of type Producer

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

Uses of Producer in rx.internal.operators

Classes in rx.internal.operators that implement Producer

Modifier and Type	Class	Description
(package private) static final class	CachedObservable.ReplayProducer<T>	Keeps track of the current request amount and the replay position for a child Subscriber.
(package private) static final class	DeferredScalarSubscriber.InnerProducer	Redirects the downstream request amount bach to the DeferredScalarSubscriber.
(package private) static final class	OnSubscribeCombineLatest.LatestCoordinator<T,R>
(package private) static final class	OnSubscribeConcatMap.ConcatMapInnerScalarProducer<T,R>
(package private) static final class	OnSubscribeDetach.DetachProducer<T>	Callbacks from the child Subscriber.
(package private) static enum	OnSubscribeDetach.TerminatedProducer	Singleton instance via enum.
(package private) static final class	OnSubscribeFromArray.FromArrayProducer<T>
(package private) static class	OnSubscribeFromAsync.BaseAsyncEmitter<T>
(package private) static final class	OnSubscribeFromAsync.BufferAsyncEmitter<T>
(package private) static final class	OnSubscribeFromAsync.DropAsyncEmitter<T>
(package private) static final class	OnSubscribeFromAsync.ErrorAsyncEmitter<T>
(package private) static final class	OnSubscribeFromAsync.LatestAsyncEmitter<T>
(package private) static final class	OnSubscribeFromAsync.NoneAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T>
(package private) static final class	OnSubscribeFromIterable.IterableProducer<T>
(package private) static final class	OnSubscribePublishMulticast.PublishProducer<T>	A Producer and Subscription that wraps a child Subscriber and manages its backpressure requests along with its unsubscription from the parent class.
(package private) static final class	OnSubscribeRange.RangeProducer
(package private) final class	OperatorBufferWithSize.BufferOverlap.BufferOverlapProducer
(package private) final class	OperatorBufferWithSize.BufferSkip.BufferSkipProducer
(package private) static final class	OperatorEagerConcatMap.EagerOuterProducer
(package private) static class	OperatorElementAt.InnerProducer	A producer that wraps another Producer and requests Long.MAX_VALUE when the first positive request() call comes in.
static final class	OperatorGroupBy.GroupByProducer
(package private) static final class	OperatorGroupBy.State<T,K>
(package private) static final class	OperatorMerge.MergeProducer<T>
(package private) static final class	OperatorOnBackpressureLatest.LatestEmitter<T>	A terminable producer which emits the latest items on request.
(package private) static final class	OperatorPublish.InnerProducer<T>	A Producer and Subscription that manages the request and unsubscription state of a child subscriber in thread-safe manner.
(package private) static final class	OperatorReplay.InnerProducer<T>	A Producer and Subscription that manages the request and unsubscription state of a child subscriber in thread-safe manner.
(package private) static final class	OperatorScan.InitialProducer<R>
(package private) final class	OperatorWindowWithSize.WindowOverlap.WindowOverlapProducer
(package private) final class	OperatorWindowWithSize.WindowSkip.WindowSkipProducer
(package private) static final class	OperatorZip.ZipProducer<R>

Fields in rx.internal.operators declared as Producer

Modifier and Type	Field	Description
(package private) final Producer	OperatorElementAt.InnerProducer.actual
(package private) Producer	OnSubscribePublishMulticast.producer	Holds the upstream producer if any, set through the parent subscriber.
(package private) Producer	OperatorReplay.ReplaySubscriber.producer	The upstream producer.
(package private) Producer	OperatorScan.InitialProducer.producer	The current producer.
(package private) Producer	OperatorSwitch.SwitchSubscriber.producer

Fields in rx.internal.operators with type parameters of type Producer

Modifier and Type	Field	Description
(package private) final AtomicReference<Producer>	OnSubscribeDetach.DetachSubscriber.producer
(package private) final AtomicReference<Producer>	OperatorMapNotification.MapNotificationSubscriber.producer

Methods in rx.internal.operators that return Producer

Modifier and Type	Method	Description
(package private) Producer	OperatorBufferWithSize.BufferExact.createProducer()
(package private) Producer	OperatorBufferWithSize.BufferOverlap.createProducer()
(package private) Producer	OperatorBufferWithSize.BufferSkip.createProducer()
(package private) Producer	OperatorWindowWithSize.WindowExact.createProducer()
(package private) Producer	OperatorWindowWithSize.WindowOverlap.createProducer()
(package private) Producer	OperatorWindowWithSize.WindowSkip.createProducer()
protected Producer	OperatorOnBackpressureBuffer.BufferSubscriber.manager()

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

Modifier and Type	Method	Description
(package private) void	OperatorSwitch.SwitchSubscriber.innerProducer(Producer p, long id)
final void	DeferredScalarSubscriber.setProducer(Producer p)
void	OnSubscribeConcatMap.ConcatMapInnerSubscriber.setProducer(Producer p)
void	OnSubscribeDetach.DetachSubscriber.setProducer(Producer p)
void	OnSubscribeFilter.FilterSubscriber.setProducer(Producer p)
void	OnSubscribeMap.MapSubscriber.setProducer(Producer p)
void	OnSubscribePublishMulticast.ParentSubscriber.setProducer(Producer p)
(package private) void	OnSubscribePublishMulticast.setProducer(Producer p)	Sets the main producer and issues the prefetch amount.
void	OperatorCast.CastSubscriber.setProducer(Producer p)
void	OperatorGroupBy.GroupBySubscriber.setProducer(Producer s)
void	OperatorMapNotification.MapNotificationSubscriber.setProducer(Producer p)
void	OperatorMapPair.MapPairSubscriber.setProducer(Producer p)
void	OperatorReplay.ReplaySubscriber.setProducer(Producer p)
void	OperatorScan.InitialProducer.setProducer(Producer p)
void	OperatorSwitch.InnerSubscriber.setProducer(Producer p)
void	OperatorSwitchIfEmpty.AlternateSubscriber.setProducer(Producer producer)
void	OperatorSwitchIfEmpty.ParentSubscriber.setProducer(Producer producer)
void	OperatorTimeoutBase.TimeoutSubscriber.setProducer(Producer p)
void	OperatorWithLatestFromMany.WithLatestMainSubscriber.setProducer(Producer p)

Constructors in rx.internal.operators with parameters of type Producer

Modifier	Constructor	Description
	InnerProducer(Producer actual)

Uses of Producer in rx.internal.producers

Classes in rx.internal.producers that implement Producer

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

Fields in rx.internal.producers declared as Producer

Modifier and Type	Field	Description
(package private) Producer	ProducerArbiter.currentProducer
(package private) Producer	ProducerObserverArbiter.currentProducer
(package private) Producer	ProducerArbiter.missedProducer
(package private) Producer	ProducerObserverArbiter.missedProducer
(package private) static final Producer	ProducerArbiter.NULL_PRODUCER
(package private) static final Producer	ProducerObserverArbiter.NULL_PRODUCER

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

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

Uses of Producer in rx.internal.util

Classes in rx.internal.util that implement Producer

Modifier and Type	Class	Description
final class	BackpressureDrainManager	Manages the producer-backpressure-consumer interplay by matching up available elements with requested elements and/or terminal events.
(package private) static final class	ScalarSynchronousObservable.ScalarAsyncProducer<T>	Represents a producer which schedules the emission of a scalar value on the first positive request via the given scheduler callback.
(package private) static final class	ScalarSynchronousObservable.WeakSingleProducer<T>	This is the weak version of SingleProducer that uses plain fields to avoid reentrancy and as such is not threadsafe for concurrent request() calls.

Methods in rx.internal.util that return Producer

Modifier and Type	Method	Description
(package private) static <T> Producer	ScalarSynchronousObservable.createProducer(Subscriber<? super T> s, T v)	Creates a scalar producer depending on the state of STRONG_MODE.

Uses of Producer in rx.observables

Classes in rx.observables that implement Producer

Modifier and Type	Class	Description
(package private) static final class	AsyncOnSubscribe.AsyncOuterManager<S,T>
(package private) static final class	SyncOnSubscribe.SubscriptionProducer<S,T>	Contains the producer loop that reacts to downstream requests of work.

Fields in rx.observables declared as Producer

Modifier and Type	Field	Description
(package private) Producer	AsyncOnSubscribe.AsyncOuterManager.concatProducer

Methods in rx.observables with parameters of type Producer

Modifier and Type	Method	Description
(package private) void	AsyncOnSubscribe.AsyncOuterManager.setConcatProducer(Producer p)

Uses of Producer in rx.subjects

Classes in rx.subjects that implement Producer

Modifier and Type	Class	Description
(package private) static final class	ReplaySubject.ReplayProducer<T>	A producer and subscription implementation that tracks the current replay position of a particular subscriber.
(package private) static final class	UnicastSubject.State<T>	The single-consumption replaying state.