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) 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 CompositeDisposable

Modifier	Constructor	Description
(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 CompositeDisposable

Modifier and Type	Field	Description
(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 CompositeDisposable

Modifier and Type	Field	Description
(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 CompositeDisposable

Modifier	Constructor	Description
(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 CompositeDisposable

Modifier and Type	Field	Description
(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 CompositeDisposable

Modifier and Type	Field	Description
(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 CompositeDisposable

Modifier	Constructor	Description
(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 CompositeDisposable

Modifier and Type	Field	Description
(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 CompositeDisposable

Modifier and Type	Method	Description
(package private) static void	IoScheduler.CachedWorkerPool.evictExpiredWorkers(ConcurrentLinkedQueue<IoScheduler.ThreadWorker> expiringWorkerQueue, CompositeDisposable allWorkers)