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.