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. EMPTYA 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. TERMINATEDA 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) voidObservableCache. add(ObservableCache.CacheDisposable<T> consumer)Atomically adds the consumer to theObservableCache.observerscopy-on-write array if the source has not yet terminated.(package private) voidObservableCache. remove(ObservableCache.CacheDisposable<T> consumer)Atomically removes the consumer from theObservableCache.observerscopy-on-write array.(package private) voidObservableCache. 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.
-