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> void	QueueDrainHelper.drainLoop(SimplePlainQueue<T> q, Observer<? super U> a, boolean delayError, Disposable dispose, ObservableQueueDrain<T,U> qd)
static <T,U> void	QueueDrainHelper.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.