Uses of Class
io.reactivex.rxjava3.operators.SpscArrayQueue
Packages that use SpscArrayQueue
Package
Description
-
Uses of SpscArrayQueue in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as SpscArrayQueueModifier and TypeFieldDescription(package private) final SpscArrayQueue
<T> BlockingFlowableIterable.BlockingFlowableIterator.queue
-
Uses of SpscArrayQueue in io.reactivex.rxjava3.internal.operators.parallel
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as SpscArrayQueueModifier and TypeFieldDescription(package private) final SpscArrayQueue
<T> ParallelRunOn.BaseRunOnSubscriber.queue
Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type SpscArrayQueueModifierConstructorDescription(package private)
BaseRunOnSubscriber
(int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker) (package private)
RunOnConditionalSubscriber
(ConditionalSubscriber<? super T> actual, int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker) (package private)
RunOnSubscriber
(org.reactivestreams.Subscriber<? super T> actual, int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker)