Uses of Class
io.reactivex.rxjava3.disposables.CompositeDisposable

Packages that use CompositeDisposable

Package	Description
io.reactivex.rxjava3.internal.operators.completable
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.internal.schedulers

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)