Uses of Interface
io.reactivex.rxjava3.operators.SimplePlainQueue
-
Packages that use SimplePlainQueue Package Description io.reactivex.rxjava3.internal.observers io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.internal.operators.observable io.reactivex.rxjava3.internal.operators.parallel io.reactivex.rxjava3.internal.queue io.reactivex.rxjava3.internal.subscribers io.reactivex.rxjava3.internal.util io.reactivex.rxjava3.operators Classes and interfaces for writing advanced operators within and outside RxJava. -
-
Uses of SimplePlainQueue in io.reactivex.rxjava3.internal.observers
Fields in io.reactivex.rxjava3.internal.observers declared as SimplePlainQueue Modifier and Type Field Description protected SimplePlainQueue<U>
QueueDrainObserver. queue
Constructors in io.reactivex.rxjava3.internal.observers with parameters of type SimplePlainQueue Constructor Description QueueDrainObserver(Observer<? super V> actual, SimplePlainQueue<U> queue)
-
Uses of SimplePlainQueue in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as SimplePlainQueue Modifier and Type Field Description (package private) SimplePlainQueue<T>
FlowableCreate.SerializedEmitter. queue
(package private) SimplePlainQueue<U>
FlowableFlatMap.MergeSubscriber. queue
(package private) SimplePlainQueue<T>
FlowableMergeWithMaybe.MergeWithObserver. queue
(package private) SimplePlainQueue<T>
FlowableMergeWithSingle.MergeWithObserver. queue
(package private) SimplePlainQueue<T>
FlowableOnBackpressureBuffer.BackpressureBufferSubscriber. queue
(package private) SimplePlainQueue<R>
FlowableScanSeed.ScanSeedSubscriber. queue
(package private) SimplePlainQueue<java.lang.Object>
FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber. queue
(package private) SimplePlainQueue<java.lang.Object>
FlowableWindowTimed.AbstractWindowSubscriber. queue
Methods in io.reactivex.rxjava3.internal.operators.flowable that return SimplePlainQueue Modifier and Type Method Description (package private) SimplePlainQueue<T>
FlowableMergeWithMaybe.MergeWithObserver. getOrCreateQueue()
(package private) SimplePlainQueue<T>
FlowableMergeWithSingle.MergeWithObserver. getOrCreateQueue()
-
Uses of SimplePlainQueue in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as SimplePlainQueue Modifier and Type Field Description (package private) SimplePlainQueue<U>
ObservableFlatMap.MergeObserver. queue
(package private) SimplePlainQueue<T>
ObservableMergeWithMaybe.MergeWithObserver. queue
(package private) SimplePlainQueue<T>
ObservableMergeWithSingle.MergeWithObserver. queue
(package private) SimplePlainQueue<java.lang.Object>
ObservableWindowBoundarySelector.WindowBoundaryMainObserver. queue
(package private) SimplePlainQueue<java.lang.Object>
ObservableWindowTimed.AbstractWindowObserver. queue
Methods in io.reactivex.rxjava3.internal.operators.observable that return SimplePlainQueue Modifier and Type Method Description (package private) SimplePlainQueue<T>
ObservableMergeWithMaybe.MergeWithObserver. getOrCreateQueue()
(package private) SimplePlainQueue<T>
ObservableMergeWithSingle.MergeWithObserver. getOrCreateQueue()
-
Uses of SimplePlainQueue in io.reactivex.rxjava3.internal.operators.parallel
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as SimplePlainQueue Modifier and Type Field Description (package private) SimplePlainQueue<T>
ParallelJoin.JoinInnerSubscriber. queue
Methods in io.reactivex.rxjava3.internal.operators.parallel that return SimplePlainQueue Modifier and Type Method Description (package private) SimplePlainQueue<T>
ParallelJoin.JoinInnerSubscriber. getQueue()
-
Uses of SimplePlainQueue in io.reactivex.rxjava3.internal.queue
Classes in io.reactivex.rxjava3.internal.queue that implement SimplePlainQueue Modifier and Type Class Description class
MpscLinkedQueue<T>
A multi-producer single consumer unbounded queue. -
Uses of SimplePlainQueue in io.reactivex.rxjava3.internal.subscribers
Fields in io.reactivex.rxjava3.internal.subscribers declared as SimplePlainQueue Modifier and Type Field Description protected SimplePlainQueue<U>
QueueDrainSubscriber. queue
Constructors in io.reactivex.rxjava3.internal.subscribers with parameters of type SimplePlainQueue Constructor Description QueueDrainSubscriber(org.reactivestreams.Subscriber<? super V> actual, SimplePlainQueue<U> queue)
-
Uses of SimplePlainQueue in io.reactivex.rxjava3.internal.util
Methods in io.reactivex.rxjava3.internal.util with parameters of type SimplePlainQueue Modifier and Type Method Description static <T,U>
voidQueueDrainHelper. drainLoop(SimplePlainQueue<T> q, Observer<? super U> a, boolean delayError, Disposable dispose, ObservableQueueDrain<T,U> qd)
static <T,U>
voidQueueDrainHelper. drainMaxLoop(SimplePlainQueue<T> q, org.reactivestreams.Subscriber<? super U> a, boolean delayError, Disposable dispose, QueueDrain<T,U> qd)
Drain the queue but give up with an error if there aren't enough requests. -
Uses of SimplePlainQueue in io.reactivex.rxjava3.operators
Classes in io.reactivex.rxjava3.operators that implement SimplePlainQueue Modifier and Type Class Description class
SpscArrayQueue<E>
A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.class
SpscLinkedArrayQueue<T>
A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.
-