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

Packages that use QueueFuseable

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.subscribers
io.reactivex.rxjava3.internal.subscriptions
io.reactivex.rxjava3.operators	Classes and interfaces for writing advanced operators within and outside RxJava.

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

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

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

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

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

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 QueueFuseable in io.reactivex.rxjava3.internal.observers

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

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.

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

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

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

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

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

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 QueueFuseable in io.reactivex.rxjava3.internal.subscribers

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

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.

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

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

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 QueueFuseable in io.reactivex.rxjava3.operators

Subinterfaces of QueueFuseable 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	QueueSubscription<T>	An interface extending SimpleQueue and Subscription and allows negotiating the fusion mode between subsequent operators of the Flowable base reactive type.