Uses of Interface
rx.Producer
Packages that use Producer
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
Classes extending the Observable base reactive class and implementing
the Observer interface at the same time (aka hot Observables).
-
Uses of Producer in rx
Modifier and TypeMethodDescriptionvoid
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 ProducerModifier and TypeClassDescription(package private) static final class
Keeps track of the current request amount and the replay position for a child Subscriber.(package private) static final class
Redirects the downstream request amount bach to the DeferredScalarSubscriber.(package private) static final class
(package private) static final class
(package private) static final class
Callbacks from the child Subscriber.(package private) static enum
Singleton instance via enum.(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
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
(package private) final class
(package private) final class
(package private) static final class
(package private) static class
A producer that wraps another Producer and requests Long.MAX_VALUE when the first positive request() call comes in.static final class
(package private) static final class
(package private) static final class
(package private) static final class
A terminable producer which emits the latest items on request.(package private) static final class
A Producer and Subscription that manages the request and unsubscription state of a child subscriber in thread-safe manner.(package private) static final class
A Producer and Subscription that manages the request and unsubscription state of a child subscriber in thread-safe manner.(package private) static final class
(package private) final class
(package private) final class
(package private) static final class
Fields in rx.internal.operators declared as ProducerModifier and TypeFieldDescription(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 ProducerModifier and TypeFieldDescription(package private) final AtomicReference
<Producer> OnSubscribeDetach.DetachSubscriber.producer
(package private) final AtomicReference
<Producer> OperatorMapNotification.MapNotificationSubscriber.producer
Methods in rx.internal.operators that return ProducerModifier and TypeMethodDescription(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 ProducerModifier and TypeMethodDescription(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 -
Uses of Producer in rx.internal.producers
Classes in rx.internal.producers that implement ProducerModifier and TypeClassDescriptionfinal class
Producer that allows changing an underlying producer atomically and correctly resume with the accumulated requests.final class
Producer that serializes any event emission with requesting and producer changes.final class
Producer that holds an unbounded (or custom) queue, handles terminal events, enqueues values and relays them to a child subscriber on request.final class
Producer that holds an unbounded (or custom) queue to enqueue values and relays them to a child subscriber on request.final class
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
A producer which emits a single value and completes the child on the first positive request.Fields in rx.internal.producers declared as ProducerModifier and TypeFieldDescription(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 ProducerModifier and TypeMethodDescriptionvoid
ProducerArbiter.setProducer
(Producer newProducer) void
ProducerObserverArbiter.setProducer
(Producer p) -
Uses of Producer in rx.internal.util
Classes in rx.internal.util that implement ProducerModifier and TypeClassDescriptionfinal class
Manages the producer-backpressure-consumer interplay by matching up available elements with requested elements and/or terminal events.(package private) static final class
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
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 ProducerModifier and TypeMethodDescription(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 ProducerModifier and TypeClassDescription(package private) static final class
(package private) static final class
Contains the producer loop that reacts to downstream requests of work.Fields in rx.observables declared as ProducerModifier and TypeFieldDescription(package private) Producer
AsyncOnSubscribe.AsyncOuterManager.concatProducer
Methods in rx.observables with parameters of type ProducerModifier and TypeMethodDescription(package private) void
AsyncOnSubscribe.AsyncOuterManager.setConcatProducer
(Producer p) -
Uses of Producer in rx.subjects
Classes in rx.subjects that implement ProducerModifier and TypeClassDescription(package private) static final class
A producer and subscription implementation that tracks the current replay position of a particular subscriber.(package private) static final class
The single-consumption replaying state.