Uses of Class
io.reactivex.rxjava3.disposables.CompositeDisposable
-
-
Uses of CompositeDisposable in io.reactivex.rxjava3.internal.operators.completable
Fields in io.reactivex.rxjava3.internal.operators.completable declared as CompositeDisposable Modifier and Type Field Description (package private) CompositeDisposable
CompletableAmb.Amb. set
(package private) CompositeDisposable
CompletableMerge.CompletableMergeSubscriber. set
(package private) CompositeDisposable
CompletableMergeArray.InnerCompletableObserver. set
(package private) CompositeDisposable
CompletableMergeArrayDelayError.MergeInnerCompletableObserver. set
(package private) CompositeDisposable
CompletableMergeIterable.MergeCompletableObserver. set
(package private) CompositeDisposable
CompletableTimeout.DisposeTask. set
private CompositeDisposable
CompletableTimeout.TimeOutObserver. set
Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type CompositeDisposable Constructor Description Amb(java.util.concurrent.atomic.AtomicBoolean once, CompositeDisposable set, CompletableObserver observer)
DisposeTask(java.util.concurrent.atomic.AtomicBoolean once, CompositeDisposable set, CompletableObserver observer)
InnerCompletableObserver(CompletableObserver actual, java.util.concurrent.atomic.AtomicBoolean once, CompositeDisposable set, int n)
MergeCompletableObserver(CompletableObserver actual, CompositeDisposable set, java.util.concurrent.atomic.AtomicInteger wip)
MergeInnerCompletableObserver(CompletableObserver observer, CompositeDisposable set, AtomicThrowable error, java.util.concurrent.atomic.AtomicInteger wip)
TimeOutObserver(CompositeDisposable set, java.util.concurrent.atomic.AtomicBoolean once, CompletableObserver observer)
-
Uses of CompositeDisposable in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as CompositeDisposable Modifier and Type Field Description (package private) CompositeDisposable
FlowableGroupJoin.GroupJoinSubscription. disposables
(package private) CompositeDisposable
FlowableJoin.JoinSubscription. disposables
(package private) CompositeDisposable
FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber. resources
(package private) CompositeDisposable
FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber. set
(package private) CompositeDisposable
FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber. set
(package private) CompositeDisposable
FlowableFlatMapMaybe.FlatMapMaybeSubscriber. set
(package private) CompositeDisposable
FlowableFlatMapSingle.FlatMapSingleSubscriber. set
(package private) CompositeDisposable
FlowableBufferBoundary.BufferBoundarySubscriber. subscribers
-
Uses of CompositeDisposable in io.reactivex.rxjava3.internal.operators.maybe
Fields in io.reactivex.rxjava3.internal.operators.maybe declared as CompositeDisposable Modifier and Type Field Description (package private) CompositeDisposable
MaybeAmb.AmbMaybeObserver. set
(package private) CompositeDisposable
MaybeMergeArray.MergeMaybeObserver. set
Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type CompositeDisposable Constructor Description AmbMaybeObserver(MaybeObserver<? super T> downstream, CompositeDisposable set, java.util.concurrent.atomic.AtomicBoolean winner)
-
Uses of CompositeDisposable in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as CompositeDisposable Modifier and Type Field Description (package private) CompositeDisposable
ObservableGroupJoin.GroupJoinDisposable. disposables
(package private) CompositeDisposable
ObservableJoin.JoinDisposable. disposables
(package private) CompositeDisposable
ObservableBufferBoundary.BufferBoundaryObserver. observers
(package private) CompositeDisposable
ObservableWindowBoundarySelector.WindowBoundaryMainObserver. resources
(package private) CompositeDisposable
ObservableFlatMapCompletable.FlatMapCompletableMainObserver. set
(package private) CompositeDisposable
ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver. set
(package private) CompositeDisposable
ObservableFlatMapMaybe.FlatMapMaybeObserver. set
(package private) CompositeDisposable
ObservableFlatMapSingle.FlatMapSingleObserver. set
-
Uses of CompositeDisposable in io.reactivex.rxjava3.internal.operators.single
Fields in io.reactivex.rxjava3.internal.operators.single declared as CompositeDisposable Modifier and Type Field Description (package private) CompositeDisposable
SingleAmb.AmbSingleObserver. set
(package private) CompositeDisposable
SingleEquals.InnerObserver. set
Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type CompositeDisposable Constructor Description AmbSingleObserver(SingleObserver<? super T> observer, CompositeDisposable set, java.util.concurrent.atomic.AtomicBoolean winner)
InnerObserver(int index, CompositeDisposable set, java.lang.Object[] values, SingleObserver<? super java.lang.Boolean> observer, java.util.concurrent.atomic.AtomicInteger count)
-
Uses of CompositeDisposable in io.reactivex.rxjava3.internal.schedulers
Fields in io.reactivex.rxjava3.internal.schedulers declared as CompositeDisposable Modifier and Type Field Description (package private) CompositeDisposable
IoScheduler.CachedWorkerPool. allWorkers
(package private) CompositeDisposable
ExecutorScheduler.ExecutorWorker. tasks
private CompositeDisposable
IoScheduler.EventLoopWorker. tasks
(package private) CompositeDisposable
SingleScheduler.ScheduledWorker. tasks
private CompositeDisposable
ComputationScheduler.EventLoopWorker. timed
Methods in io.reactivex.rxjava3.internal.schedulers with parameters of type CompositeDisposable Modifier and Type Method Description (package private) static void
IoScheduler.CachedWorkerPool. evictExpiredWorkers(java.util.concurrent.ConcurrentLinkedQueue<IoScheduler.ThreadWorker> expiringWorkerQueue, CompositeDisposable allWorkers)
-