Uses of Class
rx.subscriptions.SerialSubscription
-
Packages that use SerialSubscription Package Description rx.internal.operators 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 SerialSubscription Modifier and Type Field Description (package private) SerialSubscription
CachedObservable.CacheState. connection
Holds onto the subscriber connected to source.(package private) SerialSubscription
OnSubscribeConcatMap.ConcatMapSubscriber. inner
(package private) SerialSubscription
CompletableOnSubscribeConcatArray.ConcatInnerSubscriber. sd
(package private) SerialSubscription
CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber. sd
(package private) SerialSubscription
OnSubscribeFromAsync.BaseAsyncEmitter. serial
(package private) SerialSubscription
OperatorTimeoutBase.TimeoutSubscriber. serial
(package private) SerialSubscription
OperatorRetryWithPredicate.SourceSubscriber. serialSubscription
(package private) SerialSubscription
CompletableOnSubscribeConcat.CompletableConcatSubscriber. sr
(package private) SerialSubscription
OperatorSwitch.SwitchSubscriber. ssub
private SerialSubscription
OperatorSwitchIfEmpty.ParentSubscriber. ssub
(package private) SerialSubscription
OperatorWindowWithObservableFactory.SourceSubscriber. ssub
Constructors in rx.internal.operators with parameters of type SerialSubscription Constructor Description ParentSubscriber(Subscriber<? super T> child, SerialSubscription ssub, ProducerArbiter arbiter, Observable<? extends T> alternate)
SourceSubscriber(Subscriber<? super T> child, Func2<java.lang.Integer,java.lang.Throwable,java.lang.Boolean> predicate, Scheduler.Worker inner, SerialSubscription serialSubscription, ProducerArbiter pa)
TimeoutSubscriber(SerializedSubscriber<T> serializedSubscriber, OperatorTimeoutBase.TimeoutStub<T> timeoutStub, SerialSubscription serial, Observable<? extends T> other, Scheduler.Worker inner)
-