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 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 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 theObservableCache.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 theObservableCache.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.
-