Uses of Class
io.reactivex.rxjava3.internal.operators.flowable.FlowableCache.CacheSubscription

Packages that use FlowableCache.CacheSubscription

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

Uses of FlowableCache.CacheSubscription in io.reactivex.rxjava3.internal.operators.flowable

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FlowableCache.CacheSubscription

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

Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FlowableCache.CacheSubscription

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