Uses of Class
rx.internal.operators.CachedObservable.ReplayProducer
-
Packages that use CachedObservable.ReplayProducer 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 CachedObservable.ReplayProducer in rx.internal.operators
Fields in rx.internal.operators declared as CachedObservable.ReplayProducer Modifier and Type Field Description (package private) static 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.ReplayProducer Modifier and Type Method Description void
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.
-