Uses of Class
io.reactivex.rxjava3.internal.observers.BasicIntQueueDisposable

Packages that use BasicIntQueueDisposable

Package	Description
io.reactivex.rxjava3.internal.jdk8
io.reactivex.rxjava3.internal.observers
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 BasicIntQueueDisposable in io.reactivex.rxjava3.internal.jdk8

Subclasses of BasicIntQueueDisposable in io.reactivex.rxjava3.internal.jdk8

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>

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

Subclasses of BasicIntQueueDisposable in io.reactivex.rxjava3.internal.observers

Modifier and Type	Class	Description
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 BasicIntQueueDisposable in io.reactivex.rxjava3.internal.operators.maybe

Subclasses of BasicIntQueueDisposable in io.reactivex.rxjava3.internal.operators.maybe

Modifier and Type	Class	Description
(package private) static class	MaybeToObservable.MaybeToObservableObserver<T>

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

Subclasses of BasicIntQueueDisposable in io.reactivex.rxjava3.internal.operators.observable

Modifier and Type	Class	Description
(package private) static class	ObservableDoFinally.DoFinallyObserver<T>
(package private) static class	ObservableFlatMapCompletable.FlatMapCompletableMainObserver<T>
(package private) static class	ObservableObserveOn.ObserveOnObserver<T>
(package private) static class	ObservableRange.RangeDisposable
(package private) static class	ObservableRangeLong.RangeDisposable

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

Subclasses of BasicIntQueueDisposable in io.reactivex.rxjava3.internal.operators.single

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

Uses of BasicIntQueueDisposable in io.reactivex.rxjava3.subjects

Subclasses of BasicIntQueueDisposable in io.reactivex.rxjava3.subjects

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

Fields in io.reactivex.rxjava3.subjects declared as BasicIntQueueDisposable

Modifier and Type	Field	Description
(package private) BasicIntQueueDisposable<T>	UnicastSubject.wip	The wip counter and QueueDisposable surface.