Uses of Class
io.reactivex.rxjava3.operators.SpscArrayQueue
-
Packages that use SpscArrayQueue Package Description io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.internal.operators.parallel -
-
Uses of SpscArrayQueue in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as SpscArrayQueue Modifier and Type Field Description (package private) 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 SpscArrayQueue Modifier and Type Field Description (package private) SpscArrayQueue<T>
ParallelRunOn.BaseRunOnSubscriber. queue
Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type SpscArrayQueue Constructor Description BaseRunOnSubscriber(int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker)
RunOnConditionalSubscriber(ConditionalSubscriber<? super T> actual, int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker)
RunOnSubscriber(org.reactivestreams.Subscriber<? super T> actual, int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker)
-