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

Packages that use QueueSubscription

Package	Description
io.reactivex.rxjava3.internal.fuseable	Base interfaces and types for supporting operator-fusion.
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.subscribers
io.reactivex.rxjava3.internal.subscriptions

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

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

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 QueueSubscription in io.reactivex.rxjava3.internal.operators.flowable

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

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

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

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

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

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

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

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 QueueSubscription

Modifier and Type	Field	Description
protected QueueSubscription<T>	BasicFuseableConditionalSubscriber.qs	The upstream's QueueSubscription if not null.
protected QueueSubscription<T>	BasicFuseableSubscriber.qs	The upstream's QueueSubscription if not null.

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

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

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.