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) 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 SerialSubscription

Modifier	Constructor	Description
(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)