Uses of Class
io.reactivex.rxjava3.internal.operators.observable.ObservableCache.CacheDisposable

Packages that use ObservableCache.CacheDisposable

Package	Description
io.reactivex.rxjava3.internal.operators.observable

Uses of ObservableCache.CacheDisposable in io.reactivex.rxjava3.internal.operators.observable

Fields in io.reactivex.rxjava3.internal.operators.observable declared as ObservableCache.CacheDisposable

Modifier and Type	Field	Description
(package private) static final ObservableCache.CacheDisposable[]	ObservableCache.EMPTY	A shared instance of an empty array of observers to avoid creating a new empty array when all observers dispose.
(package private) static final ObservableCache.CacheDisposable[]	ObservableCache.TERMINATED	A shared instance indicating the source has no more events and there is no need to remember observers anymore.

Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObservableCache.CacheDisposable

Modifier and Type	Method	Description
(package private) void	ObservableCache.add(ObservableCache.CacheDisposable<T> consumer)	Atomically adds the consumer to the ObservableCache.observers copy-on-write array if the source has not yet terminated.
(package private) void	ObservableCache.remove(ObservableCache.CacheDisposable<T> consumer)	Atomically removes the consumer from the ObservableCache.observers copy-on-write array.
(package private) void	ObservableCache.replay(ObservableCache.CacheDisposable<T> consumer)	Replays the contents of this cache to the given consumer based on its current state and number of items requested by it.