Uses of Class
rx.subscriptions.CompositeSubscription

Packages that use CompositeSubscription

Package	Description
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.internal.schedulers
rx.observables	Classes extending the Observable base reactive class, synchronous and asynchronous event generators.
rx.subscriptions	Default implementations for Subscription-based resource management (Subscription container types) and utility classes to construct Subscriptions from callbacks and other types.

Uses of CompositeSubscription in rx.internal.operators

Fields in rx.internal.operators declared as CompositeSubscription

Modifier and Type	Field	Description
(package private) CompositeSubscription	OnSubscribeRefCount.baseSubscription
private final CompositeSubscription	OperatorZip.Zip.childSubscription
(package private) final CompositeSubscription	OperatorBufferWithStartEndObservable.BufferingSubscriber.closingSubscriptions
(package private) final CompositeSubscription	OperatorWindowWithStartEndObservable.SourceSubscriber.csub
(package private) final CompositeSubscription	OnSubscribeGroupJoin.ResultManager.group
(package private) final CompositeSubscription	OnSubscribeJoin.ResultSink.group
(package private) final CompositeSubscription	CompletableOnSubscribeMerge.CompletableMergeSubscriber.set
(package private) CompositeSubscription	OperatorMerge.MergeSubscriber.subscriptions	Tracks the active subscriptions to sources.

Methods in rx.internal.operators that return CompositeSubscription

Modifier and Type	Method	Description
(package private) CompositeSubscription	OperatorMerge.MergeSubscriber.getOrCreateComposite()

Methods in rx.internal.operators with parameters of type CompositeSubscription

Modifier and Type	Method	Description
private Subscription	OnSubscribeRefCount.disconnect(CompositeSubscription current)
(package private) void	OnSubscribeRefCount.doSubscribe(Subscriber<? super T> subscriber, CompositeSubscription currentBase)

Constructors in rx.internal.operators with parameters of type CompositeSubscription

Modifier	Constructor	Description
	SourceSubscriber(Subscriber<? super Observable<T>> child, CompositeSubscription csub)

Uses of CompositeSubscription in rx.internal.schedulers

Fields in rx.internal.schedulers declared as CompositeSubscription

Modifier and Type	Field	Description
private final CompositeSubscription	CachedThreadScheduler.CachedWorkerPool.allWorkers
private final CompositeSubscription	CachedThreadScheduler.EventLoopWorker.innerSubscription
(package private) final CompositeSubscription	ScheduledAction.Remover.parent
(package private) final CompositeSubscription	ExecutorScheduler.ExecutorSchedulerWorker.tasks
private final CompositeSubscription	EventLoopsScheduler.EventLoopWorker.timed

Methods in rx.internal.schedulers with parameters of type CompositeSubscription

Modifier and Type	Method	Description
void	ScheduledAction.addParent(CompositeSubscription parent)	Adds a parent CompositeSubscription to this ScheduledAction so when the action is cancelled or terminates, it can remove itself from this parent.
ScheduledAction	NewThreadWorker.scheduleActual(Action0 action, long delayTime, TimeUnit unit, CompositeSubscription parent)

Constructors in rx.internal.schedulers with parameters of type CompositeSubscription

Modifier	Constructor	Description
	Remover(ScheduledAction s, CompositeSubscription parent)
	ScheduledAction(Action0 action, CompositeSubscription parent)

Uses of CompositeSubscription in rx.observables

Fields in rx.observables declared as CompositeSubscription

Modifier and Type	Field	Description
(package private) final CompositeSubscription	AsyncOnSubscribe.AsyncOuterManager.subscriptions

Uses of CompositeSubscription in rx.subscriptions

Methods in rx.subscriptions that return CompositeSubscription

Modifier and Type	Method	Description
static CompositeSubscription	Subscriptions.from(Subscription... subscriptions)	Converts a set of Subscriptions into a CompositeSubscription that groups the multiple Subscriptions together and unsubscribes from all of them together.