Uses of Interface
io.reactivex.rxjava3.operators.QueueDisposable
Packages that use QueueDisposable
Package
Description
Base interfaces and types for supporting operator-fusion.
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 QueueDisposableModifier and TypeClassDescriptionenum
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 QueueDisposableModifier and TypeClassDescriptionclass
Represents an empty, async-onlyQueueFuseable
instance.final class
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 QueueDisposableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of QueueDisposable in io.reactivex.rxjava3.internal.observers
Classes in io.reactivex.rxjava3.internal.observers that implement QueueDisposableModifier and TypeClassDescriptionclass
Base class for a fuseable intermediate observer.class
An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.class
An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.class
Represents a fuseable container for a single value.class
A fuseable Observer that can generate 0 or 1 resulting value.Fields in io.reactivex.rxjava3.internal.observers declared as QueueDisposableModifier and TypeFieldDescriptionprotected 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 QueueDisposableModifier and TypeClassDescriptionstatic final class
-
Uses of QueueDisposable in io.reactivex.rxjava3.internal.operators.maybe
Classes in io.reactivex.rxjava3.internal.operators.maybe that implement QueueDisposableModifier and TypeClassDescription(package private) static final class
(package private) static final class
-
Uses of QueueDisposable in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement QueueDisposableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
Represents a Disposable that signals one onNext followed by an onComplete.Fields in io.reactivex.rxjava3.internal.operators.observable declared as QueueDisposableModifier and TypeFieldDescription(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 QueueDisposableModifier and TypeClassDescription(package private) static final class
(package private) static final class
-
Uses of QueueDisposable in io.reactivex.rxjava3.subjects
Classes in io.reactivex.rxjava3.subjects that implement QueueDisposableModifier and TypeClassDescription(package private) static final class
(package private) final class