Uses of Class
rx.subscriptions.CompositeSubscription
Packages that use CompositeSubscription
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
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 CompositeSubscriptionModifier and TypeFieldDescription(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 CompositeSubscriptionModifier and TypeMethodDescription(package private) CompositeSubscription
OperatorMerge.MergeSubscriber.getOrCreateComposite()
Methods in rx.internal.operators with parameters of type CompositeSubscriptionModifier and TypeMethodDescriptionprivate 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 CompositeSubscriptionModifierConstructorDescriptionSourceSubscriber
(Subscriber<? super Observable<T>> child, CompositeSubscription csub) -
Uses of CompositeSubscription in rx.internal.schedulers
Fields in rx.internal.schedulers declared as CompositeSubscriptionModifier and TypeFieldDescriptionprivate 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 CompositeSubscriptionModifier and TypeMethodDescriptionvoid
ScheduledAction.addParent
(CompositeSubscription parent) Adds a parentCompositeSubscription
to thisScheduledAction
so when the action is cancelled or terminates, it can remove itself from this parent.NewThreadWorker.scheduleActual
(Action0 action, long delayTime, TimeUnit unit, CompositeSubscription parent) Constructors in rx.internal.schedulers with parameters of type CompositeSubscriptionModifierConstructorDescriptionRemover
(ScheduledAction s, CompositeSubscription parent) ScheduledAction
(Action0 action, CompositeSubscription parent) -
Uses of CompositeSubscription in rx.observables
Fields in rx.observables declared as CompositeSubscriptionModifier and TypeFieldDescription(package private) final CompositeSubscription
AsyncOnSubscribe.AsyncOuterManager.subscriptions
-
Uses of CompositeSubscription in rx.subscriptions
Methods in rx.subscriptions that return CompositeSubscriptionModifier and TypeMethodDescriptionstatic CompositeSubscription
Subscriptions.from
(Subscription... subscriptions) Converts a set ofSubscription
s into aCompositeSubscription
that groups the multiple Subscriptions together and unsubscribes from all of them together.