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.observers
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.observable
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.

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.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.

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.flowable

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

Modifier and Type	Class	Description
static final class	FlowableFromCompletable.FromCompletableObserver<T>

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
static final class	ObservableFromCompletable.FromCompletableObserver<T>
static final class	ObservableScalarXMap.ScalarDisposable<T>	Represents a Disposable that signals one onNext followed by an onComplete.

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.

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.