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