Uses of Class
rx.internal.operators.OperatorReplay.InnerProducer

Packages that use OperatorReplay.InnerProducer

Package	Description
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.

Uses of OperatorReplay.InnerProducer in rx.internal.operators

Fields in rx.internal.operators declared as OperatorReplay.InnerProducer

Modifier and Type	Field	Description
(package private) static final OperatorReplay.InnerProducer[]	OperatorReplay.ReplaySubscriber.EMPTY	Indicates an empty array of inner producers.
(package private) OperatorReplay.InnerProducer<T>[]	OperatorReplay.ReplaySubscriber.producersCache	Contains a copy of the producers.
(package private) static final OperatorReplay.InnerProducer[]	OperatorReplay.ReplaySubscriber.TERMINATED	Indicates a terminated ReplaySubscriber.

Fields in rx.internal.operators with type parameters of type OperatorReplay.InnerProducer

Modifier and Type	Field	Description
(package private) List<OperatorReplay.InnerProducer<T>>	OperatorReplay.ReplaySubscriber.coordinationQueue	The queue that holds producers with request changes that need to be coordinated.
(package private) final OpenHashSet<OperatorReplay.InnerProducer<T>>	OperatorReplay.ReplaySubscriber.producers	Tracks the subscribed producers.

Methods in rx.internal.operators that return OperatorReplay.InnerProducer

Modifier and Type	Method	Description
(package private) OperatorReplay.InnerProducer<T>[]	OperatorReplay.ReplaySubscriber.copyProducers()

Methods in rx.internal.operators with parameters of type OperatorReplay.InnerProducer

Modifier and Type	Method	Description
(package private) boolean	OperatorReplay.ReplaySubscriber.add(OperatorReplay.InnerProducer<T> producer)	Atomically try adding a new InnerProducer to this Subscriber or return false if this Subscriber was terminated.
(package private) void	OperatorReplay.ReplaySubscriber.manageRequests(OperatorReplay.InnerProducer<T> inner)	Coordinates the request amounts of various child Subscribers.
(package private) void	OperatorReplay.ReplaySubscriber.remove(OperatorReplay.InnerProducer<T> producer)	Atomically removes the given producer from the producers array.
final void	OperatorReplay.BoundedReplayBuffer.replay(OperatorReplay.InnerProducer<T> output)
void	OperatorReplay.ReplayBuffer.replay(OperatorReplay.InnerProducer<T> output)	Tries to replay the buffered values to the subscriber inside the output if there is new value and requests available at the same time.
void	OperatorReplay.UnboundedReplayBuffer.replay(OperatorReplay.InnerProducer<T> output)