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 CompositeSubscription
OperatorZip.Zip. childSubscription
(package private) CompositeSubscription
OperatorBufferWithStartEndObservable.BufferingSubscriber. closingSubscriptions
(package private) CompositeSubscription
OperatorWindowWithStartEndObservable.SourceSubscriber. csub
(package private) CompositeSubscription
OnSubscribeGroupJoin.ResultManager. group
(package private) CompositeSubscription
OnSubscribeJoin.ResultSink. group
(package private) 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 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 CompositeSubscription
CachedThreadScheduler.CachedWorkerPool. allWorkers
private CompositeSubscription
CachedThreadScheduler.EventLoopWorker. innerSubscription
(package private) CompositeSubscription
ScheduledAction.Remover. parent
(package private) CompositeSubscription
ExecutorScheduler.ExecutorSchedulerWorker. tasks
private 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 parentCompositeSubscription
to thisScheduledAction
so when the action is cancelled or terminates, it can remove itself from this parent.ScheduledAction
NewThreadWorker. scheduleActual(Action0 action, long delayTime, java.util.concurrent.TimeUnit unit, CompositeSubscription parent)
Constructors in rx.internal.schedulers with parameters of type CompositeSubscription 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) 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 ofSubscription
s into aCompositeSubscription
that groups the multiple Subscriptions together and unsubscribes from all of them together.
-