Uses of Interface
io.reactivex.rxjava3.operators.SimpleQueue

Packages that use SimpleQueue

Package	Description
io.reactivex.rxjava3.internal.disposables
io.reactivex.rxjava3.internal.fuseable	Base interfaces and types for supporting operator-fusion.
io.reactivex.rxjava3.internal.jdk8
io.reactivex.rxjava3.internal.observers
io.reactivex.rxjava3.internal.operators.completable
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.maybe
io.reactivex.rxjava3.internal.operators.mixed
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.operators.parallel
io.reactivex.rxjava3.internal.operators.single
io.reactivex.rxjava3.internal.queue
io.reactivex.rxjava3.internal.subscribers
io.reactivex.rxjava3.internal.subscriptions
io.reactivex.rxjava3.internal.util
io.reactivex.rxjava3.operators	Classes and interfaces for writing advanced operators within and outside RxJava.
io.reactivex.rxjava3.processors	Classes representing so-called hot backpressure-aware sources, aka processors, that implement the FlowableProcessor class, the Reactive Streams Processor interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive Streams Publisher.
io.reactivex.rxjava3.subjects	Classes representing so-called hot sources, aka subjects, that implement a base reactive class and the respective consumer type at once to allow forms of multicasting events to multiple consumers as well as consuming another base reactive type of their kind.

Uses of SimpleQueue in io.reactivex.rxjava3.internal.disposables

Classes in io.reactivex.rxjava3.internal.disposables that implement SimpleQueue

Modifier and Type	Class	Description
enum	EmptyDisposable	Represents a stateless empty Disposable that reports being always empty and disposed.

Uses of SimpleQueue in io.reactivex.rxjava3.internal.fuseable

Classes in io.reactivex.rxjava3.internal.fuseable that implement SimpleQueue

Modifier and Type	Class	Description
class	AbstractEmptyQueueFuseable<T>	Represents an empty, async-only QueueFuseable instance.
final class	CancellableQueueFuseable<T>	Represents an empty, async-only QueueFuseable instance that tracks and exposes a canceled/disposed state.

Uses of SimpleQueue in io.reactivex.rxjava3.internal.jdk8

Classes in io.reactivex.rxjava3.internal.jdk8 that implement SimpleQueue

Modifier and Type	Class	Description
(package private) static final class	FlowableCollectWithCollector.CollectorSubscriber<T,A,R>
(package private) static final class	FlowableFromCompletionStage.CompletionStageHandler<T>
(package private) static class	FlowableFromStream.AbstractStreamSubscription<T>
(package private) static final class	FlowableFromStream.StreamConditionalSubscription<T>
(package private) static final class	FlowableFromStream.StreamSubscription<T>
(package private) static final class	FlowableMapOptional.MapOptionalConditionalSubscriber<T,R>
(package private) static final class	FlowableMapOptional.MapOptionalSubscriber<T,R>
(package private) static final class	MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver<T,R>
(package private) static final class	MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver<T,R>
(package private) static final class	ObservableCollectWithCollector.CollectorObserver<T,A,R>
(package private) static final class	ObservableFromCompletionStage.CompletionStageHandler<T>
(package private) static final class	ObservableFromStream.StreamDisposable<T>
(package private) static final class	ObservableMapOptional.MapOptionalObserver<T,R>
(package private) static final class	ParallelCollector.ParallelCollectorSubscriber<T,A,R>

Fields in io.reactivex.rxjava3.internal.jdk8 declared as SimpleQueue

Modifier and Type	Field	Description
(package private) SimpleQueue<T>	FlowableFlatMapStream.FlatMapStreamSubscriber.queue

Uses of SimpleQueue in io.reactivex.rxjava3.internal.observers

Classes in io.reactivex.rxjava3.internal.observers that implement SimpleQueue

Modifier and Type	Class	Description
class	BasicFuseableObserver<T,R>	Base class for a fuseable intermediate observer.
class	BasicIntQueueDisposable<T>	An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.
class	BasicQueueDisposable<T>	An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.
class	DeferredScalarDisposable<T>	Represents a fuseable container for a single value.
class	DeferredScalarObserver<T,R>	A fuseable Observer that can generate 0 or 1 resulting value.

Fields in io.reactivex.rxjava3.internal.observers declared as SimpleQueue

Modifier and Type	Field	Description
(package private) SimpleQueue<T>	InnerQueuedObserver.queue

Methods in io.reactivex.rxjava3.internal.observers that return SimpleQueue

Modifier and Type	Method	Description
SimpleQueue<T>	InnerQueuedObserver.queue()

Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.completable

Fields in io.reactivex.rxjava3.internal.operators.completable declared as SimpleQueue

Modifier and Type	Field	Description
(package private) SimpleQueue<CompletableSource>	CompletableConcat.CompletableConcatSubscriber.queue

Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.flowable

Classes in io.reactivex.rxjava3.internal.operators.flowable that implement SimpleQueue

Modifier and Type	Class	Description
(package private) static final class	FlowableAll.AllSubscriber<T>
(package private) static final class	FlowableAny.AnySubscriber<T>
(package private) static final class	FlowableCollect.CollectSubscriber<T,U>
(package private) static final class	FlowableCombineLatest.CombineLatestCoordinator<T,R>
(package private) static final class	FlowableCount.CountSubscriber
(package private) static final class	FlowableDistinct.DistinctSubscriber<T,K>
(package private) static final class	FlowableDistinctUntilChanged.DistinctUntilChangedConditionalSubscriber<T,K>
(package private) static final class	FlowableDistinctUntilChanged.DistinctUntilChangedSubscriber<T,K>
(package private) static final class	FlowableDoAfterNext.DoAfterConditionalSubscriber<T>
(package private) static final class	FlowableDoAfterNext.DoAfterSubscriber<T>
(package private) static final class	FlowableDoFinally.DoFinallyConditionalSubscriber<T>
(package private) static final class	FlowableDoFinally.DoFinallySubscriber<T>
(package private) static final class	FlowableDoOnEach.DoOnEachConditionalSubscriber<T>
(package private) static final class	FlowableDoOnEach.DoOnEachSubscriber<T>
(package private) static final class	FlowableElementAt.ElementAtSubscriber<T>
(package private) static final class	FlowableFilter.FilterConditionalSubscriber<T>
(package private) static final class	FlowableFilter.FilterSubscriber<T>
(package private) static final class	FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber<T>
(package private) static final class	FlowableFlattenIterable.FlattenIterableSubscriber<T,R>
(package private) static final class	FlowableFromArray.ArrayConditionalSubscription<T>
(package private) static final class	FlowableFromArray.ArraySubscription<T>
(package private) static class	FlowableFromArray.BaseArraySubscription<T>
static final class	FlowableFromCompletable.FromCompletableObserver<T>
(package private) static class	FlowableFromIterable.BaseRangeSubscription<T>
(package private) static final class	FlowableFromIterable.IteratorConditionalSubscription<T>
(package private) static final class	FlowableFromIterable.IteratorSubscription<T>
(package private) static final class	FlowableGroupBy.State<T,K>
(package private) static final class	FlowableIgnoreElements.IgnoreElementsSubscriber<T>
(package private) static final class	FlowableMap.MapConditionalSubscriber<T,U>
(package private) static final class	FlowableMap.MapSubscriber<T,U>
(package private) static class	FlowableObserveOn.BaseObserveOnSubscriber<T>
(package private) static final class	FlowableObserveOn.ObserveOnConditionalSubscriber<T>
(package private) static final class	FlowableObserveOn.ObserveOnSubscriber<T>
(package private) static final class	FlowableOnBackpressureBuffer.BackpressureBufferSubscriber<T>
(package private) static class	FlowableRange.BaseRangeSubscription
(package private) static final class	FlowableRange.RangeConditionalSubscription
(package private) static final class	FlowableRange.RangeSubscription
(package private) static class	FlowableRangeLong.BaseRangeSubscription
(package private) static final class	FlowableRangeLong.RangeConditionalSubscription
(package private) static final class	FlowableRangeLong.RangeSubscription
(package private) static final class	FlowableReduce.ReduceSubscriber<T>
(package private) static final class	FlowableSequenceEqual.EqualCoordinator<T>
(package private) static final class	FlowableSingle.SingleElementSubscriber<T>
(package private) static final class	FlowableTakeLastOne.TakeLastOneSubscriber<T>
(package private) static final class	FlowableToList.ToListSubscriber<T,U extends Collection<? super T>>

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as SimpleQueue

Modifier and Type	Field	Description
(package private) SimpleQueue<T>	FlowableConcatMap.BaseConcatMapSubscriber.queue
(package private) SimpleQueue<T>	FlowableConcatMapScheduler.BaseConcatMapSubscriber.queue
(package private) SimpleQueue<U>	FlowableFlatMap.InnerSubscriber.queue
(package private) SimpleQueue<T>	FlowableFlattenIterable.FlattenIterableSubscriber.queue
(package private) SimpleQueue<T>	FlowableObserveOn.BaseObserveOnSubscriber.queue
(package private) SimpleQueue<T>	FlowablePublish.PublishConnection.queue
(package private) SimpleQueue<T>	FlowablePublishMulticast.MulticastProcessor.queue
(package private) SimpleQueue<T>	FlowableSequenceEqual.EqualSubscriber.queue
(package private) SimpleQueue<R>	FlowableSwitchMap.SwitchMapInnerSubscriber.queue
(package private) SimpleQueue<T>	FlowableZip.ZipSubscriber.queue

Methods in io.reactivex.rxjava3.internal.operators.flowable that return SimpleQueue

Modifier and Type	Method	Description
(package private) SimpleQueue<U>	FlowableFlatMap.MergeSubscriber.getMainQueue()

Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type SimpleQueue

Modifier and Type	Method	Description
(package private) boolean	FlowableFlattenIterable.FlattenIterableSubscriber.checkTerminated(boolean d, boolean empty, org.reactivestreams.Subscriber<?> a, SimpleQueue<?> q)
(package private) void	FlowableGroupJoin.GroupJoinSubscription.fail(Throwable exc, org.reactivestreams.Subscriber<?> a, SimpleQueue<?> q)
(package private) void	FlowableJoin.JoinSubscription.fail(Throwable exc, org.reactivestreams.Subscriber<?> a, SimpleQueue<?> q)

Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.maybe

Subinterfaces of SimpleQueue in io.reactivex.rxjava3.internal.operators.maybe

Modifier and Type	Interface	Description
(package private) static interface	MaybeMergeArray.SimpleQueueWithConsumerIndex<T>

Classes in io.reactivex.rxjava3.internal.operators.maybe that implement SimpleQueue

Modifier and Type	Class	Description
(package private) static final class	MaybeFlatMapIterableFlowable.FlatMapIterableObserver<T,R>
(package private) static final class	MaybeFlatMapIterableObservable.FlatMapIterableObserver<T,R>
(package private) static final class	MaybeMergeArray.ClqSimpleQueue<T>
(package private) static final class	MaybeMergeArray.MergeMaybeObserver<T>
(package private) static final class	MaybeMergeArray.MpscFillOnceSimpleQueue<T>
(package private) static final class	MaybeToFlowable.MaybeToFlowableSubscriber<T>
(package private) static final class	MaybeToObservable.MaybeToObservableObserver<T>

Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.mixed

Fields in io.reactivex.rxjava3.internal.operators.mixed declared as SimpleQueue

Modifier and Type	Field	Description
(package private) SimpleQueue<T>	ConcatMapXMainObserver.queue
(package private) SimpleQueue<T>	ConcatMapXMainSubscriber.queue

Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.observable

Classes in io.reactivex.rxjava3.internal.operators.observable that implement SimpleQueue

Modifier and Type	Class	Description
(package private) static final class	ObservableDistinct.DistinctObserver<T,K>
(package private) static final class	ObservableDistinctUntilChanged.DistinctUntilChangedObserver<T,K>
(package private) static final class	ObservableDoAfterNext.DoAfterObserver<T>
(package private) static final class	ObservableDoFinally.DoFinallyObserver<T>
(package private) static final class	ObservableFilter.FilterObserver<T>
(package private) static final class	ObservableFlatMapCompletable.FlatMapCompletableMainObserver<T>
(package private) static final class	ObservableFromArray.FromArrayDisposable<T>
static final class	ObservableFromCompletable.FromCompletableObserver<T>
(package private) static final class	ObservableFromIterable.FromIterableDisposable<T>
(package private) static final class	ObservableMap.MapObserver<T,U>
(package private) static final class	ObservableObserveOn.ObserveOnObserver<T>
(package private) static final class	ObservableRange.RangeDisposable
(package private) static final class	ObservableRangeLong.RangeDisposable
static final class	ObservableScalarXMap.ScalarDisposable<T>	Represents a Disposable that signals one onNext followed by an onComplete.

Fields in io.reactivex.rxjava3.internal.operators.observable declared as SimpleQueue

Modifier and Type	Field	Description
(package private) SimpleQueue<T>	ObservableConcatMap.ConcatMapDelayErrorObserver.queue
(package private) SimpleQueue<T>	ObservableConcatMap.SourceObserver.queue
(package private) SimpleQueue<T>	ObservableConcatMapEager.ConcatMapEagerMainObserver.queue
(package private) SimpleQueue<T>	ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.queue
(package private) SimpleQueue<T>	ObservableConcatMapScheduler.ConcatMapObserver.queue
(package private) SimpleQueue<U>	ObservableFlatMap.InnerObserver.queue
(package private) SimpleQueue<T>	ObservableObserveOn.ObserveOnObserver.queue
(package private) SimpleQueue<R>	ObservableSwitchMap.SwitchMapInnerObserver.queue

Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.parallel

Classes in io.reactivex.rxjava3.internal.operators.parallel that implement SimpleQueue

Modifier and Type	Class	Description
(package private) static final class	ParallelCollect.ParallelCollectSubscriber<T,C>
(package private) static final class	ParallelReduce.ParallelReduceSubscriber<T,R>
(package private) static final class	ParallelReduceFull.ParallelReduceFullMainSubscriber<T>

Fields in io.reactivex.rxjava3.internal.operators.parallel declared as SimpleQueue

Modifier and Type	Field	Description
(package private) SimpleQueue<T>	ParallelFromPublisher.ParallelDispatcher.queue

Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.single

Classes in io.reactivex.rxjava3.internal.operators.single that implement SimpleQueue

Modifier and Type	Class	Description
(package private) static final class	SingleFlatMapIterableFlowable.FlatMapIterableObserver<T,R>
(package private) static final class	SingleFlatMapIterableObservable.FlatMapIterableObserver<T,R>
(package private) static final class	SingleToFlowable.SingleToFlowableObserver<T>
(package private) static final class	SingleToObservable.SingleToObservableObserver<T>

Uses of SimpleQueue in io.reactivex.rxjava3.internal.queue

Classes in io.reactivex.rxjava3.internal.queue that implement SimpleQueue

Modifier and Type	Class	Description
final class	MpscLinkedQueue<T>	A multi-producer single consumer unbounded queue.

Uses of SimpleQueue in io.reactivex.rxjava3.internal.subscribers

Classes in io.reactivex.rxjava3.internal.subscribers that implement SimpleQueue

Modifier and Type	Class	Description
class	BasicFuseableConditionalSubscriber<T,R>	Base class for a fuseable intermediate subscriber.
class	BasicFuseableSubscriber<T,R>	Base class for a fuseable intermediate subscriber.
class	DeferredScalarSubscriber<T,R>	A subscriber, extending a DeferredScalarSubscription, that is unbounded-in and can generate 0 or 1 resulting value.

Fields in io.reactivex.rxjava3.internal.subscribers declared as SimpleQueue

Modifier and Type	Field	Description
(package private) SimpleQueue<T>	InnerQueuedSubscriber.queue

Methods in io.reactivex.rxjava3.internal.subscribers that return SimpleQueue

Modifier and Type	Method	Description
SimpleQueue<T>	InnerQueuedSubscriber.queue()

Uses of SimpleQueue in io.reactivex.rxjava3.internal.subscriptions

Classes in io.reactivex.rxjava3.internal.subscriptions that implement SimpleQueue

Modifier and Type	Class	Description
class	BasicIntQueueSubscription<T>	Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).
class	BasicQueueSubscription<T>	Base class extending AtomicLong (wip or request accounting) and QueueSubscription (fusion).
class	DeferredScalarSubscription<T>	A subscription that signals a single value eventually.
enum	EmptySubscription	An empty subscription that does nothing other than validates the request amount.
final class	ScalarSubscription<T>	A Subscription that holds a constant value and emits it only when requested.

Uses of SimpleQueue in io.reactivex.rxjava3.internal.util

Methods in io.reactivex.rxjava3.internal.util that return SimpleQueue

Modifier and Type	Method	Description
static <T> SimpleQueue<T>	QueueDrainHelper.createQueue(int capacityHint)	Creates a queue: spsc-array if capacityHint is positive and spsc-linked-array if capacityHint is negative; in both cases, the capacity is the absolute value of prefetch.

Methods in io.reactivex.rxjava3.internal.util with parameters of type SimpleQueue

Modifier and Type	Method	Description
static <T, U> boolean	QueueDrainHelper.checkTerminated(boolean d, boolean empty, Observer<?> observer, boolean delayError, SimpleQueue<?> q, Disposable disposable, ObservableQueueDrain<T,U> qd)
static <T, U> boolean	QueueDrainHelper.checkTerminated(boolean d, boolean empty, org.reactivestreams.Subscriber<?> s, boolean delayError, SimpleQueue<?> q, QueueDrain<T,U> qd)

Uses of SimpleQueue in io.reactivex.rxjava3.operators

Subinterfaces of SimpleQueue in io.reactivex.rxjava3.operators

Modifier and Type	Interface	Description
interface	QueueDisposable<T>	An interface extending SimpleQueue and Disposable and allows negotiating the fusion mode between subsequent operators of the Observable base reactive type.
interface	QueueFuseable<T>	Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
interface	QueueSubscription<T>	An interface extending SimpleQueue and Subscription and allows negotiating the fusion mode between subsequent operators of the Flowable base reactive type.
interface	SimplePlainQueue<T>	Override of the SimpleQueue interface with no throws Throwable on poll().

Classes in io.reactivex.rxjava3.operators that implement SimpleQueue

Modifier and Type	Class	Description
final class	SpscArrayQueue<E>	A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
final 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.

Uses of SimpleQueue in io.reactivex.rxjava3.processors

Classes in io.reactivex.rxjava3.processors that implement SimpleQueue

Modifier and Type	Class	Description
(package private) static final class	AsyncProcessor.AsyncSubscription<T>
(package private) final class	UnicastProcessor.UnicastQueueSubscription

Fields in io.reactivex.rxjava3.processors declared as SimpleQueue

Modifier and Type	Field	Description
(package private) SimpleQueue<T>	MulticastProcessor.queue

Uses of SimpleQueue in io.reactivex.rxjava3.subjects

Classes in io.reactivex.rxjava3.subjects that implement SimpleQueue

Modifier and Type	Class	Description
(package private) static final class	AsyncSubject.AsyncDisposable<T>
(package private) final class	UnicastSubject.UnicastQueueDisposable

Methods in io.reactivex.rxjava3.subjects with parameters of type SimpleQueue

Modifier and Type	Method	Description
(package private) boolean	UnicastSubject.failedFast(SimpleQueue<T> q, Observer<? super T> a)