Uses of Class
rx.internal.operators.OperatorReplay.InnerProducer
Packages that use OperatorReplay.InnerProducer
Package
Description
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.InnerProducerModifier and TypeFieldDescription(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.InnerProducerModifier and TypeFieldDescription(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.InnerProducerModifier and TypeMethodDescription(package private) OperatorReplay.InnerProducer<T>[]
OperatorReplay.ReplaySubscriber.copyProducers()
Methods in rx.internal.operators with parameters of type OperatorReplay.InnerProducerModifier and TypeMethodDescription(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)