Uses of Class
rx.subscriptions.SerialSubscription
Packages that use SerialSubscription
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of SerialSubscription in rx.internal.operators
Fields in rx.internal.operators declared as SerialSubscriptionModifier and TypeFieldDescription(package private) final SerialSubscription
CachedObservable.CacheState.connection
Holds onto the subscriber connected to source.(package private) final SerialSubscription
OnSubscribeConcatMap.ConcatMapSubscriber.inner
(package private) final SerialSubscription
CompletableOnSubscribeConcatArray.ConcatInnerSubscriber.sd
(package private) final SerialSubscription
CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber.sd
(package private) final SerialSubscription
OnSubscribeFromAsync.BaseAsyncEmitter.serial
(package private) final SerialSubscription
OperatorTimeoutBase.TimeoutSubscriber.serial
(package private) final SerialSubscription
OperatorRetryWithPredicate.SourceSubscriber.serialSubscription
(package private) final SerialSubscription
CompletableOnSubscribeConcat.CompletableConcatSubscriber.sr
(package private) final SerialSubscription
OperatorSwitch.SwitchSubscriber.ssub
private final SerialSubscription
OperatorSwitchIfEmpty.ParentSubscriber.ssub
(package private) final SerialSubscription
OperatorWindowWithObservableFactory.SourceSubscriber.ssub
Constructors in rx.internal.operators with parameters of type SerialSubscriptionModifierConstructorDescription(package private)
ParentSubscriber
(Subscriber<? super T> child, SerialSubscription ssub, ProducerArbiter arbiter, Observable<? extends T> alternate) SourceSubscriber
(Subscriber<? super T> child, Func2<Integer, Throwable, Boolean> predicate, Scheduler.Worker inner, SerialSubscription serialSubscription, ProducerArbiter pa) (package private)
TimeoutSubscriber
(SerializedSubscriber<T> serializedSubscriber, OperatorTimeoutBase.TimeoutStub<T> timeoutStub, SerialSubscription serial, Observable<? extends T> other, Scheduler.Worker inner)