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 constructorSubscriber(Subscriber)
orSubscriber(Subscriber, boolean)
) then this method callssetProducer
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.
-