Uses of Class
rx.internal.operators.CachedObservable.ReplayProducer
Packages that use CachedObservable.ReplayProducer
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of CachedObservable.ReplayProducer in rx.internal.operators
Fields in rx.internal.operators declared as CachedObservable.ReplayProducerModifier and TypeFieldDescription(package private) static final CachedObservable.ReplayProducer<?>[]
CachedObservable.CacheState.EMPTY
The default empty array of producers.(package private) CachedObservable.ReplayProducer<?>[]
CachedObservable.CacheState.producers
Guarded by connection (not this).Methods in rx.internal.operators with parameters of type CachedObservable.ReplayProducerModifier and TypeMethodDescriptionvoid
CachedObservable.CacheState.addProducer
(CachedObservable.ReplayProducer<T> p) Adds a ReplayProducer to the producers array atomically.void
CachedObservable.CacheState.removeProducer
(CachedObservable.ReplayProducer<T> p) Removes the ReplayProducer (if present) from the producers array atomically.