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 class	CachedObservable.ReplayProducer<T>	Keeps track of the current request amount and the replay position for a child Subscriber.
(package private) static class	DeferredScalarSubscriber.InnerProducer	Redirects the downstream request amount bach to the DeferredScalarSubscriber.
(package private) static class	OnSubscribeCombineLatest.LatestCoordinator<T,R>
(package private) static class	OnSubscribeConcatMap.ConcatMapInnerScalarProducer<T,R>
(package private) static class	OnSubscribeDetach.DetachProducer<T>	Callbacks from the child Subscriber.
(package private) static class	OnSubscribeDetach.TerminatedProducer	Singleton instance via enum.
(package private) static class	OnSubscribeFromArray.FromArrayProducer<T>
(package private) static class	OnSubscribeFromAsync.BaseAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.BufferAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.DropAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.ErrorAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.LatestAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.NoneAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T>
(package private) static class	OnSubscribeFromIterable.IterableProducer<T>
(package private) static 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 class	OnSubscribeRange.RangeProducer
(package private) class	OperatorBufferWithSize.BufferOverlap.BufferOverlapProducer
(package private) class	OperatorBufferWithSize.BufferSkip.BufferSkipProducer
(package private) static 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 class	OperatorGroupBy.GroupByProducer
(package private) static class	OperatorGroupBy.State<T,K>
(package private) static class	OperatorMerge.MergeProducer<T>
(package private) static class	OperatorOnBackpressureLatest.LatestEmitter<T>	A terminable producer which emits the latest items on request.
(package private) static 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 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 class	OperatorScan.InitialProducer<R>
(package private) class	OperatorWindowWithSize.WindowOverlap.WindowOverlapProducer
(package private) class	OperatorWindowWithSize.WindowSkip.WindowSkipProducer
(package private) static class	OperatorZip.ZipProducer<R>

Fields in rx.internal.operators declared as Producer

Modifier and Type	Field	Description
(package private) 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) java.util.concurrent.atomic.AtomicReference<Producer>	OnSubscribeDetach.DetachSubscriber.producer
(package private) java.util.concurrent.atomic.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)
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

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
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.

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 Producer	ProducerArbiter.NULL_PRODUCER
(package private) static 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
class	BackpressureDrainManager	Manages the producer-backpressure-consumer interplay by matching up available elements with requested elements and/or terminal events.
(package private) static 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 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 class	AsyncOnSubscribe.AsyncOuterManager<S,T>
(package private) static 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 class	ReplaySubject.ReplayProducer<T>	A producer and subscription implementation that tracks the current replay position of a particular subscriber.
(package private) static class	UnicastSubject.State<T>	The single-consumption replaying state.