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.
-