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
class	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.
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 class	MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver<T,R>
(package private) static class	ObservableCollectWithCollector.CollectorObserver<T,A,R>
(package private) static class	ObservableFromCompletionStage.CompletionStageHandler<T>
(package private) static class	ObservableFromStream.StreamDisposable<T>
(package private) static 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 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 class	MaybeFlatMapIterableObservable.FlatMapIterableObserver<T,R>
(package private) static 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 class	ObservableDistinct.DistinctObserver<T,K>
(package private) static class	ObservableDistinctUntilChanged.DistinctUntilChangedObserver<T,K>
(package private) static class	ObservableDoAfterNext.DoAfterObserver<T>
(package private) static class	ObservableDoFinally.DoFinallyObserver<T>
(package private) static class	ObservableFilter.FilterObserver<T>
(package private) static class	ObservableFlatMapCompletable.FlatMapCompletableMainObserver<T>
(package private) static class	ObservableFromArray.FromArrayDisposable<T>
static class	ObservableFromCompletable.FromCompletableObserver<T>
(package private) static class	ObservableFromIterable.FromIterableDisposable<T>
(package private) static class	ObservableMap.MapObserver<T,U>
(package private) static class	ObservableObserveOn.ObserveOnObserver<T>
(package private) static class	ObservableRange.RangeDisposable
(package private) static class	ObservableRangeLong.RangeDisposable
static 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 class	SingleFlatMapIterableObservable.FlatMapIterableObserver<T,R>
(package private) static 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 class	AsyncSubject.AsyncDisposable<T>
(package private) class	UnicastSubject.UnicastQueueDisposable