Uses of Interface
io.reactivex.rxjava3.operators.SimplePlainQueue
Packages that use SimplePlainQueue
Package
Description
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 SimplePlainQueueConstructors in io.reactivex.rxjava3.internal.observers with parameters of type SimplePlainQueueModifierConstructorDescriptionQueueDrainObserver
(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 SimplePlainQueueModifier and TypeFieldDescription(package private) final 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) final SimplePlainQueue
<T> FlowableOnBackpressureBuffer.BackpressureBufferSubscriber.queue
(package private) final SimplePlainQueue
<R> FlowableScanSeed.ScanSeedSubscriber.queue
(package private) final SimplePlainQueue
<Object> FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.queue
(package private) final SimplePlainQueue
<Object> FlowableWindowTimed.AbstractWindowSubscriber.queue
Methods in io.reactivex.rxjava3.internal.operators.flowable that return SimplePlainQueueModifier and TypeMethodDescription(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 SimplePlainQueueModifier and TypeFieldDescription(package private) SimplePlainQueue
<U> ObservableFlatMap.MergeObserver.queue
(package private) SimplePlainQueue
<T> ObservableMergeWithMaybe.MergeWithObserver.queue
(package private) SimplePlainQueue
<T> ObservableMergeWithSingle.MergeWithObserver.queue
(package private) final SimplePlainQueue
<Object> ObservableWindowBoundarySelector.WindowBoundaryMainObserver.queue
(package private) final SimplePlainQueue
<Object> ObservableWindowTimed.AbstractWindowObserver.queue
Methods in io.reactivex.rxjava3.internal.operators.observable that return SimplePlainQueueModifier and TypeMethodDescription(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 SimplePlainQueueModifier and TypeFieldDescription(package private) SimplePlainQueue
<T> ParallelJoin.JoinInnerSubscriber.queue
Methods in io.reactivex.rxjava3.internal.operators.parallel that return SimplePlainQueueModifier and TypeMethodDescription(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 SimplePlainQueueModifier and TypeClassDescriptionfinal class
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 SimplePlainQueueConstructors in io.reactivex.rxjava3.internal.subscribers with parameters of type SimplePlainQueueModifierConstructorDescriptionQueueDrainSubscriber
(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 SimplePlainQueueModifier and TypeMethodDescriptionstatic <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 SimplePlainQueueModifier and TypeClassDescriptionfinal class
A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.final class
A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.