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

Packages that use QueueDisposable

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.flowable
io.reactivex.rxjava3.internal.operators.maybe
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.operators.single
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 QueueDisposable in io.reactivex.rxjava3.internal.disposables

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

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

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

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

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 QueueDisposable in io.reactivex.rxjava3.internal.jdk8

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

Modifier and Type	Class	Description
(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>

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

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

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 QueueDisposable

Modifier and Type	Field	Description
protected QueueDisposable<T>	BasicFuseableObserver.qd	The upstream's QueueDisposable if not null.

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

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

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

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

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

Modifier and Type	Class	Description
(package private) static final class	MaybeFlatMapIterableObservable.FlatMapIterableObserver<T,R>
(package private) static final class	MaybeToObservable.MaybeToObservableObserver<T>

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

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

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 QueueDisposable

Modifier and Type	Field	Description
(package private) QueueDisposable<T>	ObservableDoFinally.DoFinallyObserver.qd

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

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

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

Uses of QueueDisposable in io.reactivex.rxjava3.subjects

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

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