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-onlyQueueFuseable
instance.class
CancellableQueueFuseable<T>
Represents an empty, async-onlyQueueFuseable
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
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
-