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