Uses of Class
io.reactivex.rxjava3.internal.operators.flowable.FlowableCache.CacheSubscription
Packages that use FlowableCache.CacheSubscription
-
Uses of FlowableCache.CacheSubscription in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FlowableCache.CacheSubscriptionModifier and TypeFieldDescription(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.CacheSubscriptionModifier and TypeMethodDescription(package private) void
FlowableCache.add
(FlowableCache.CacheSubscription<T> consumer) Atomically adds the consumer to theFlowableCache.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 theFlowableCache.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.