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)