Uses of Interface
rx.Subscription

Packages that use Subscription

Package	Description
rx	Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.
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.internal.util
rx.observables	Classes extending the Observable base reactive class, synchronous and asynchronous event generators.
rx.observers	Default wrappers and implementations for the base reactive consumer classes and interfaces; utility classes for creating them from callbacks.
rx.plugins	Callback types and a central plugin handler class to hook into the lifecycle of the base reactive types and schedulers.
rx.schedulers	Scheduler implementations, value+time record classes and the standard factory class to return standard RxJava schedulers or wrap any Executor-based (thread pool) instances.
rx.subjects	Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables).
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 Subscription in rx

Classes in rx that implement Subscription

Modifier and Type	Class	Description
static class	Scheduler.Worker	Sequential Scheduler for executing actions on a single thread or event loop.
class	SingleSubscriber<T>	Provides a mechanism for receiving push-based notifications.
class	Subscriber<T>	Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.

Methods in rx with type parameters of type Subscription

Modifier and Type	Method	Description
<S extends Scheduler & Subscription> S	Scheduler.when(Func1<Observable<Observable<Completable>>,Completable> combine)	Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.

Methods in rx that return Subscription

Modifier and Type	Method	Description
abstract Subscription	Scheduler.Worker.schedule(Action0 action)	Schedules an Action for execution.
abstract Subscription	Scheduler.Worker.schedule(Action0 action, long delayTime, TimeUnit unit)	Schedules an Action for execution at some point in the future.
Subscription	Scheduler.Worker.schedulePeriodically(Action0 action, long initialDelay, long period, TimeUnit unit)	Schedules a cancelable action to be executed periodically.
final Subscription	Completable.subscribe()	Subscribes to this Completable and returns a Subscription which can be used to cancel the subscription.
final Subscription	Completable.subscribe(Action0 onComplete)	Subscribes to this Completable and calls the given Action0 when this Completable completes normally.
final Subscription	Completable.subscribe(Action0 onComplete, Action1<? super Throwable> onError)	Subscribes to this Completable and calls back either the onError or onComplete functions.
final Subscription	Observable.subscribe()	Subscribes to an Observable and ignores onNext and onCompleted emissions.
final Subscription	Observable.subscribe(Action1<? super T> onNext)	Subscribes to an Observable and provides a callback to handle the items it emits.
final Subscription	Observable.subscribe(Action1<? super T> onNext, Action1<Throwable> onError)	Subscribes to an Observable and provides callbacks to handle the items it emits and any error notification it issues.
final Subscription	Observable.subscribe(Action1<? super T> onNext, Action1<Throwable> onError, Action0 onCompleted)	Subscribes to an Observable and provides callbacks to handle the items it emits and any error or completion notification it issues.
final Subscription	Observable.subscribe(Observer<? super T> observer)	Subscribes to an Observable and provides an Observer that implements functions to handle the items the Observable emits and any error or completion notification it issues.
final Subscription	Observable.subscribe(Subscriber<? super T> subscriber)	Subscribes to an Observable and provides a Subscriber that implements functions to handle the items the Observable emits and any error or completion notification it issues.
(package private) static <T> Subscription	Observable.subscribe(Subscriber<? super T> subscriber, Observable<T> observable)
final Subscription	Single.subscribe()	Subscribes to a Single but ignore its emission or notification.
final Subscription	Single.subscribe(Action1<? super T> onSuccess)	Subscribes to a Single and provides a callback to handle the item it emits.
final Subscription	Single.subscribe(Action1<? super T> onSuccess, Action1<Throwable> onError)	Subscribes to a Single and provides callbacks to handle the item it emits or any error notification it issues.
final Subscription	Single.subscribe(Observer<? super T> observer)	Subscribes an Observer to this single and returns a Subscription that allows unsubscription.
final Subscription	Single.subscribe(SingleSubscriber<? super T> te)	Subscribes to a Single and provides a SingleSubscriber that implements functions to handle the item the Single emits or any error notification it issues.
final Subscription	Single.subscribe(Subscriber<? super T> subscriber)	Subscribes to a Single and provides a Subscriber that implements functions to handle the item the Single emits or any error notification it issues.
final Subscription	Observable.unsafeSubscribe(Subscriber<? super T> subscriber)	Subscribes to an Observable and invokes Observable.OnSubscribe function without any contract protection, error handling, unsubscribe, or execution hooks.
final Subscription	Single.unsafeSubscribe(Subscriber<? super T> subscriber)	Subscribes to a Single and invokes the Single.OnSubscribe function without any contract protection, error handling, unsubscribe, or execution hooks.

Methods in rx with parameters of type Subscription

Modifier and Type	Method	Description
final void	SingleSubscriber.add(Subscription s)	Adds a Subscription to this Subscriber's list of subscriptions if this list is not marked as unsubscribed.
final void	Subscriber.add(Subscription s)	Adds a Subscription to this Subscriber's list of subscriptions if this list is not marked as unsubscribed.
void	Completable.CompletableSubscriber.onSubscribe(Subscription d)	Called once by the Completable to set a Subscription on this instance which then can be used to cancel the subscription at any time.
void	AsyncEmitter.setSubscription(Subscription s)	Sets a Subscription on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.

Method parameters in rx with type arguments of type Subscription

Modifier and Type	Method	Description
protected final Completable	Completable.doOnLifecycle(Action1<? super Subscription> onSubscribe, Action1<? super Throwable> onError, Action0 onComplete, Action0 onAfterComplete, Action0 onUnsubscribe)	Returns a Completable instance that calls the various callbacks on the specific lifecycle events.
final Completable	Completable.doOnSubscribe(Action1<? super Subscription> onSubscribe)	Returns a Completable instance that calls the given onSubscribe callback with the disposable that child subscribers receive on subscription.

Uses of Subscription in rx.internal.operators

Classes in rx.internal.operators that implement Subscription

Modifier and Type	Class	Description
(package private) static final class	BlockingOperatorLatest.LatestObserverIterator<T>	Observer of source, iterator for output.
(package private) static final class	BlockingOperatorMostRecent.MostRecentObserver<T>
(package private) static final class	BlockingOperatorNext.NextObserver<T>
static final class	BlockingOperatorToIterator.SubscriberIterator<T>
(package private) static final class	CachedObservable.ReplayProducer<T>	Keeps track of the current request amount and the replay position for a child Subscriber.
(package private) static final class	CompletableOnSubscribeConcat.CompletableConcatSubscriber
(package private) static final class	CompletableOnSubscribeMerge.CompletableMergeSubscriber
class	DeferredScalarSubscriber<T,R>	Base class for Subscribers that consume the entire upstream and signal zero or one element (or an error) in a backpressure honoring fashion.
(package private) static final class	OnSubscribeAmb.AmbSubscriber<T>
(package private) static final class	OnSubscribeCollect.CollectSubscriber<T,R>
(package private) static final class	OnSubscribeCombineLatest.CombinerSubscriber<T,R>
(package private) static final class	OnSubscribeCombineLatest.LatestCoordinator<T,R>
(package private) static final class	OnSubscribeConcatMap.ConcatMapInnerSubscriber<T,R>
(package private) static final class	OnSubscribeConcatMap.ConcatMapSubscriber<T,R>
(package private) static final class	OnSubscribeDetach.DetachProducer<T>	Callbacks from the child Subscriber.
(package private) static final class	OnSubscribeDetach.DetachSubscriber<T>	The parent subscriber that forwards events and cleans up on a terminal state.
(package private) static final class	OnSubscribeFilter.FilterSubscriber<T>
(package private) static final class	OnSubscribeFlattenIterable.FlattenIterableSubscriber<T,R>
(package private) static class	OnSubscribeFromAsync.BaseAsyncEmitter<T>
(package private) static final class	OnSubscribeFromAsync.BufferAsyncEmitter<T>
(package private) static final class	OnSubscribeFromAsync.CancellableSubscription
(package private) static final class	OnSubscribeFromAsync.DropAsyncEmitter<T>
(package private) static final class	OnSubscribeFromAsync.ErrorAsyncEmitter<T>
(package private) static final class	OnSubscribeFromAsync.LatestAsyncEmitter<T>
(package private) static final class	OnSubscribeFromAsync.NoneAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T>
(package private) final class	OnSubscribeGroupJoin.ResultManager	Manages sub-observers and subscriptions.
(package private) final class	OnSubscribeGroupJoin.ResultManager.LeftDurationObserver	Observe left duration and apply termination.
(package private) final class	OnSubscribeGroupJoin.ResultManager.LeftObserver	Observe the left source.
(package private) final class	OnSubscribeGroupJoin.ResultManager.RightDurationObserver	Observe right duration and apply termination.
(package private) final class	OnSubscribeGroupJoin.ResultManager.RightObserver	Observe the right source.
(package private) final class	OnSubscribeGroupJoin.WindowObservableFunc.WindowSubscriber	Observe activities on the window.
(package private) final class	OnSubscribeJoin.ResultSink.LeftSubscriber	Observes the left values.
(package private) final class	OnSubscribeJoin.ResultSink.LeftSubscriber.LeftDurationSubscriber	Observes the left duration.
(package private) final class	OnSubscribeJoin.ResultSink.RightSubscriber	Observes the right values.
(package private) final class	OnSubscribeJoin.ResultSink.RightSubscriber.RightDurationSubscriber	Observe the right duration.
(package private) static final class	OnSubscribeMap.MapSubscriber<T,R>
(package private) static final class	OnSubscribeOnAssembly.OnAssemblySubscriber<T>
(package private) static final class	OnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber<T>
final class	OnSubscribePublishMulticast<T>	Multicasts notifications coming through its input Subscriber view to its client Subscribers via lockstep backpressure mode.
(package private) static final class	OnSubscribePublishMulticast.ParentSubscriber<T>	The subscriber that must be used for subscribing to the upstream source.
(package private) static final class	OnSubscribePublishMulticast.PublishProducer<T>	A Producer and Subscription that wraps a child Subscriber and manages its backpressure requests along with its unsubscription from the parent class.
(package private) static final class	OnSubscribeReduce.ReduceSubscriber<T>
(package private) static final class	OnSubscribeReduceSeed.ReduceSeedSubscriber<T,R>
(package private) static final class	OnSubscribeTakeLastOne.TakeLastOneSubscriber<T>
(package private) static final class	OnSubscribeUsing.DisposeAction<Resource>
(package private) final class	OperatorBufferWithSingleObservable.BufferingSubscriber
(package private) static final class	OperatorBufferWithSize.BufferExact<T>
(package private) static final class	OperatorBufferWithSize.BufferOverlap<T>
(package private) static final class	OperatorBufferWithSize.BufferSkip<T>
(package private) final class	OperatorBufferWithStartEndObservable.BufferingSubscriber
(package private) final class	OperatorBufferWithTime.ExactSubscriber	Subscriber when exact timed chunking is required.
(package private) final class	OperatorBufferWithTime.InexactSubscriber	Subscriber when the buffer chunking time and length differ.
(package private) static final class	OperatorCast.CastSubscriber<T,R>
(package private) static final class	OperatorDoOnRequest.ParentSubscriber<T>
(package private) static final class	OperatorEagerConcatMap.EagerInnerSubscriber<T>
(package private) static final class	OperatorEagerConcatMap.EagerOuterSubscriber<T,R>
static final class	OperatorGroupBy.GroupBySubscriber<T,K,V>
(package private) static final class	OperatorGroupBy.State<T,K>
(package private) static final class	OperatorMapNotification.MapNotificationSubscriber<T,R>
(package private) static final class	OperatorMapPair.MapPairSubscriber<T,U,R>
(package private) static class	OperatorMaterialize.ParentSubscriber<T>
(package private) static final class	OperatorMerge.InnerSubscriber<T>
(package private) static final class	OperatorMerge.MergeSubscriber<T>	The subscriber that observes Observables.
(package private) static final class	OperatorObserveOn.ObserveOnSubscriber<T>	Observe through individual queue per observer.
(package private) static final class	OperatorOnBackpressureBuffer.BufferSubscriber<T>
(package private) static final class	OperatorOnBackpressureLatest.LatestEmitter<T>	A terminable producer which emits the latest items on request.
(package private) static final class	OperatorOnBackpressureLatest.LatestSubscriber<T>
(package private) static final class	OperatorPublish.InnerProducer<T>	A Producer and Subscription that manages the request and unsubscription state of a child subscriber in thread-safe manner.
(package private) static final class	OperatorPublish.PublishSubscriber<T>
(package private) static final class	OperatorReplay.InnerProducer<T>	A Producer and Subscription that manages the request and unsubscription state of a child subscriber in thread-safe manner.
(package private) static final class	OperatorReplay.ReplaySubscriber<T>
(package private) static final class	OperatorRetryWithPredicate.SourceSubscriber<T>
(package private) static final class	OperatorSampleWithTime.SamplerSubscriber<T>	The source subscriber and sampler.
(package private) static final class	OperatorSingle.ParentSubscriber<T>
(package private) static final class	OperatorSwitch.InnerSubscriber<T>
(package private) static final class	OperatorSwitch.SwitchSubscriber<T>
(package private) static final class	OperatorSwitchIfEmpty.AlternateSubscriber<T>
(package private) static final class	OperatorSwitchIfEmpty.ParentSubscriber<T>
(package private) static final class	OperatorTakeLast.TakeLastSubscriber<T>
(package private) static final class	OperatorTakeLastTimed.TakeLastTimedSubscriber<T>
(package private) static final class	OperatorTakeTimed.TakeSubscriber<T>	Subscribed to source and scheduled on a worker.
(package private) final class	OperatorTakeUntilPredicate.ParentSubscriber	Subscriber returned to the upstream.
(package private) static final class	OperatorTimeoutBase.TimeoutSubscriber<T>
(package private) static final class	OperatorWindowWithObservable.BoundarySubscriber<T,U>	Observes the boundary.
(package private) static final class	OperatorWindowWithObservable.SourceSubscriber<T>	Observes the source.
(package private) static final class	OperatorWindowWithObservableFactory.BoundarySubscriber<T,U>	Observes the boundary.
(package private) static final class	OperatorWindowWithObservableFactory.SourceSubscriber<T,U>	Observes the source.
(package private) static final class	OperatorWindowWithSize.WindowExact<T>
(package private) static final class	OperatorWindowWithSize.WindowOverlap<T>
(package private) static final class	OperatorWindowWithSize.WindowSkip<T>
(package private) final class	OperatorWindowWithStartEndObservable.SourceSubscriber
(package private) final class	OperatorWindowWithTime.ExactSubscriber	Subscriber with exact, non-overlapping windows.
(package private) final class	OperatorWindowWithTime.InexactSubscriber	Subscriber with inexact, potentially overlapping or discontinuous windows.
(package private) static final class	OperatorWithLatestFromMany.WithLatestMainSubscriber<T,R>
(package private) static final class	OperatorWithLatestFromMany.WithLatestOtherSubscriber
(package private) final class	OperatorZip.Zip.InnerSubscriber
(package private) final class	OperatorZip.ZipSubscriber
(package private) static final class	SingleDoAfterTerminate.SingleDoAfterTerminateSubscriber<T>
(package private) static final class	SingleOnSubscribeMap.MapSubscriber<T,R>

Fields in rx.internal.operators declared as Subscription

Modifier and Type	Field	Description
(package private) final Subscription	OperatorWindowWithSize.WindowExact.cancel
(package private) final Subscription	OperatorWindowWithSize.WindowOverlap.cancel
(package private) final Subscription	OperatorWindowWithSize.WindowSkip.cancel
(package private) Subscription	OperatorMulticast.guardedSubscription
private final Subscription	OnSubscribeGroupJoin.WindowObservableFunc.WindowSubscriber.ref

Fields in rx.internal.operators with type parameters of type Subscription

Modifier and Type	Field	Description
(package private) final Action1<? super Subscription>	OnSubscribeAutoConnect.connection

Methods in rx.internal.operators that return Subscription

Modifier and Type	Method	Description
private Subscription	OnSubscribeRefCount.disconnect(CompositeSubscription current)

Methods in rx.internal.operators that return types with arguments of type Subscription

Modifier and Type	Method	Description
private Action1<Subscription>	OnSubscribeRefCount.onSubscribe(Subscriber<? super T> subscriber, AtomicBoolean writeLocked)

Methods in rx.internal.operators with parameters of type Subscription

Modifier and Type	Method	Description
protected void	OnSubscribeJoin.ResultSink.LeftSubscriber.expire(int id, Subscription resource)
(package private) void	OnSubscribeJoin.ResultSink.RightSubscriber.expire(int id, Subscription resource)
void	CompletableOnSubscribeConcat.CompletableConcatSubscriber.ConcatInnerSubscriber.onSubscribe(Subscription d)
void	CompletableOnSubscribeConcatArray.ConcatInnerSubscriber.onSubscribe(Subscription d)
void	CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber.onSubscribe(Subscription d)
void	OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber.onSubscribe(Subscription d)
final void	OnSubscribeFromAsync.BaseAsyncEmitter.setSubscription(Subscription s)

Method parameters in rx.internal.operators with type arguments of type Subscription

Modifier and Type	Method	Description
void	OperatorMulticast.connect(Action1<? super Subscription> connection)
void	OperatorPublish.connect(Action1<? super Subscription> connection)
void	OperatorReplay.connect(Action1<? super Subscription> connection)

Constructors in rx.internal.operators with parameters of type Subscription

Modifier	Constructor	Description
	WindowSubscriber(Subscriber<? super T> subscriber, Subscription ref)

Constructor parameters in rx.internal.operators with type arguments of type Subscription

Modifier	Constructor	Description
	OnSubscribeAutoConnect(ConnectableObservable<? extends T> source, int numberOfSubscribers, Action1<? super Subscription> connection)

Uses of Subscription in rx.internal.schedulers

Classes in rx.internal.schedulers that implement Subscription

Modifier and Type	Class	Description
(package private) static final class	CachedThreadScheduler.EventLoopWorker
(package private) static final class	CachedThreadScheduler.ThreadWorker
(package private) static final class	EventLoopsScheduler.EventLoopWorker
(package private) static final class	EventLoopsScheduler.PoolWorker
(package private) static final class	ExecutorScheduler.ExecutorSchedulerWorker	Worker that schedules tasks on the executor indirectly through a trampoline mechanism.
private class	ImmediateScheduler.InnerImmediateScheduler
class	NewThreadWorker
final class	ScheduledAction	A Runnable that executes an Action0 and can be cancelled.
(package private) final class	ScheduledAction.FutureCompleter	Cancels the captured future if the caller of the call method is not the same as the runner of the outer ScheduledAction to prevent unnecessary self-interrupting if the unsubscription happens from the same thread.
(package private) static final class	ScheduledAction.Remover	Remove a child subscription from a composite when unsubscribing.
(package private) static final class	ScheduledAction.Remover2	Remove a child subscription from a composite when unsubscribing.
class	SchedulerWhen	Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.
private static class	SchedulerWhen.DelayedAction
private static class	SchedulerWhen.ImmediateAction
private static class	SchedulerWhen.ScheduledAction
(package private) static final class	TrampolineScheduler.InnerCurrentThreadScheduler

Fields in rx.internal.schedulers declared as Subscription

Modifier and Type	Field	Description
private static final Subscription	SchedulerWhen.SUBSCRIBED
private final Subscription	SchedulerWhen.subscription
private static final Subscription	SchedulerWhen.UNSUBSCRIBED

Methods in rx.internal.schedulers that return Subscription

Modifier and Type	Method	Description
protected Subscription	SchedulerWhen.DelayedAction.callActual(Scheduler.Worker actualWorker)
protected Subscription	SchedulerWhen.ImmediateAction.callActual(Scheduler.Worker actualWorker)
protected abstract Subscription	SchedulerWhen.ScheduledAction.callActual(Scheduler.Worker actualWorker)
private Subscription	TrampolineScheduler.InnerCurrentThreadScheduler.enqueue(Action0 action, long execTime)
Subscription	CachedThreadScheduler.EventLoopWorker.schedule(Action0 action)
Subscription	CachedThreadScheduler.EventLoopWorker.schedule(Action0 action, long delayTime, TimeUnit unit)
Subscription	EventLoopsScheduler.EventLoopWorker.schedule(Action0 action)
Subscription	EventLoopsScheduler.EventLoopWorker.schedule(Action0 action, long delayTime, TimeUnit unit)
Subscription	ExecutorScheduler.ExecutorSchedulerWorker.schedule(Action0 action)
Subscription	ExecutorScheduler.ExecutorSchedulerWorker.schedule(Action0 action, long delayTime, TimeUnit unit)
Subscription	ImmediateScheduler.InnerImmediateScheduler.schedule(Action0 action)
Subscription	ImmediateScheduler.InnerImmediateScheduler.schedule(Action0 action, long delayTime, TimeUnit unit)
Subscription	NewThreadWorker.schedule(Action0 action)
Subscription	NewThreadWorker.schedule(Action0 action, long delayTime, TimeUnit unit)
Subscription	TrampolineScheduler.InnerCurrentThreadScheduler.schedule(Action0 action)
Subscription	TrampolineScheduler.InnerCurrentThreadScheduler.schedule(Action0 action, long delayTime, TimeUnit unit)
Subscription	EventLoopsScheduler.scheduleDirect(Action0 action)	Schedules the action directly on one of the event loop workers without the additional infrastructure and checking.

Methods in rx.internal.schedulers with parameters of type Subscription

Modifier and Type	Method	Description
void	ScheduledAction.add(Subscription s)	Adds a general Subscription to this ScheduledAction that will be unsubscribed if the underlying action completes or the this scheduled action is cancelled.

Uses of Subscription in rx.internal.util

Classes in rx.internal.util that implement Subscription

Modifier and Type	Class	Description
final class	ActionSubscriber<T>	A Subscriber that forwards the onXXX method calls to callbacks.
final class	IndexedRingBuffer<E>	Add/Remove without object allocation (after initial construction).
final class	ObserverSubscriber<T>	Wraps an Observer and forwards the onXXX method calls to it.
class	RxRingBuffer	This assumes Spsc or Spmc usage.
final class	SubscriptionList	Subscription that represents a group of Subscriptions that are unsubscribed together.

Fields in rx.internal.util with type parameters of type Subscription

Modifier and Type	Field	Description
(package private) final Func1<Action0,Subscription>	ScalarSynchronousObservable.ScalarAsyncOnSubscribe.onSchedule
(package private) final Func1<Action0,Subscription>	ScalarSynchronousObservable.ScalarAsyncProducer.onSchedule
private List<Subscription>	SubscriptionList.subscriptions

Methods in rx.internal.util with parameters of type Subscription

Modifier and Type	Method	Description
void	SubscriptionList.add(Subscription s)	Adds a new Subscription to this SubscriptionList if the SubscriptionList is not yet unsubscribed.
static void	BlockingUtils.awaitForComplete(CountDownLatch latch, Subscription subscription)	Blocks and waits for a Subscription to complete.
void	SubscriptionList.remove(Subscription s)

Method parameters in rx.internal.util with type arguments of type Subscription

Modifier and Type	Method	Description
private static void	SubscriptionList.unsubscribeFromAll(Collection<Subscription> subscriptions)

Constructors in rx.internal.util with parameters of type Subscription

Modifier	Constructor	Description
	SubscriptionList(Subscription s)	Constructs a SubscriptionList with the given initial child subscription.
	SubscriptionList(Subscription... subscriptions)	Constructs a SubscriptionList with the given initial child subscriptions.

Constructor parameters in rx.internal.util with type arguments of type Subscription

Modifier	Constructor	Description
(package private)	ScalarAsyncOnSubscribe(T value, Func1<Action0,Subscription> onSchedule)
	ScalarAsyncProducer(Subscriber<? super T> actual, T value, Func1<Action0,Subscription> onSchedule)

Uses of Subscription in rx.observables

Classes in rx.observables that implement Subscription

Modifier and Type	Class	Description
(package private) static final class	AsyncOnSubscribe.AsyncOuterManager<S,T>
(package private) static final class	SyncOnSubscribe.SubscriptionProducer<S,T>	Contains the producer loop that reacts to downstream requests of work.

Methods in rx.observables that return Subscription

Modifier and Type	Method	Description
final Subscription	ConnectableObservable.connect()	Instructs the ConnectableObservable to begin emitting the items from its underlying Observable to its Subscribers.

Method parameters in rx.observables with type arguments of type Subscription

Modifier and Type	Method	Description
Observable<T>	ConnectableObservable.autoConnect(int numberOfSubscribers, Action1<? super Subscription> connection)	Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it and calls the specified callback with the Subscription associated with the established connection.
abstract void	ConnectableObservable.connect(Action1<? super Subscription> connection)	Instructs the ConnectableObservable to begin emitting the items from its underlying Observable to its Subscribers.

Uses of Subscription in rx.observers

Classes in rx.observers that implement Subscription

Modifier and Type	Class	Description
class	AsyncCompletableSubscriber	An abstract base class for CompletableSubscriber implementations that want to expose an unsubscription capability.
(package private) static final class	AsyncCompletableSubscriber.Unsubscribed
final class	SafeCompletableSubscriber	Wraps another CompletableSubscriber and handles exceptions thrown from onError and onCompleted.
class	SafeSubscriber<T>	SafeSubscriber is a wrapper around Subscriber that ensures that the Subscriber complies with the Observable contract.
class	SerializedSubscriber<T>	Enforces single-threaded, serialized, ordered execution of SerializedSubscriber.onNext(T), SerializedSubscriber.onCompleted(), and SerializedSubscriber.onError(java.lang.Throwable).
class	TestSubscriber<T>	A TestSubscriber is a variety of Subscriber that you can use for unit testing, to perform assertions, inspect received events, or wrap a mocked Subscriber.

Fields in rx.observers declared as Subscription

Modifier and Type	Field	Description
(package private) Subscription	SafeCompletableSubscriber.s

Fields in rx.observers with type parameters of type Subscription

Modifier and Type	Field	Description
private final AtomicReference<Subscription>	AsyncCompletableSubscriber.upstream	Holds onto a deferred subscription and allows asynchronous cancellation before the call to onSubscribe() by the upstream.

Methods in rx.observers with parameters of type Subscription

Modifier and Type	Method	Description
final void	AsyncCompletableSubscriber.onSubscribe(Subscription d)
void	SafeCompletableSubscriber.onSubscribe(Subscription d)

Uses of Subscription in rx.plugins

Fields in rx.plugins with type parameters of type Subscription

Modifier and Type	Field	Description
(package private) static Func1<Subscription,Subscription>	RxJavaHooks.onObservableReturn
(package private) static Func1<Subscription,Subscription>	RxJavaHooks.onObservableReturn
(package private) static Func1<Subscription,Subscription>	RxJavaHooks.onSingleReturn
(package private) static Func1<Subscription,Subscription>	RxJavaHooks.onSingleReturn

Methods in rx.plugins that return Subscription

Modifier and Type	Method	Description
static Subscription	RxJavaHooks.onObservableReturn(Subscription subscription)	Hook to call before the Observable.subscribe() method is about to return a Subscription.
static Subscription	RxJavaHooks.onSingleReturn(Subscription subscription)	Hook to call before the Single.subscribe() method is about to return a Subscription.
<T> Subscription	RxJavaObservableExecutionHook.onSubscribeReturn(Subscription subscription)	Deprecated.
<T> Subscription	RxJavaSingleExecutionHook.onSubscribeReturn(Subscription subscription)	Deprecated.

Methods in rx.plugins that return types with arguments of type Subscription

Modifier and Type	Method	Description
static Func1<Subscription,Subscription>	RxJavaHooks.getOnObservableReturn()	Returns the current Observable onReturn hook function or null if it is set to the default pass-through.
static Func1<Subscription,Subscription>	RxJavaHooks.getOnObservableReturn()	Returns the current Observable onReturn hook function or null if it is set to the default pass-through.
static Func1<Subscription,Subscription>	RxJavaHooks.getOnSingleReturn()	Returns the current Single onReturn hook function or null if it is set to the default pass-through.
static Func1<Subscription,Subscription>	RxJavaHooks.getOnSingleReturn()	Returns the current Single onReturn hook function or null if it is set to the default pass-through.

Methods in rx.plugins with parameters of type Subscription

Modifier and Type	Method	Description
static Subscription	RxJavaHooks.onObservableReturn(Subscription subscription)	Hook to call before the Observable.subscribe() method is about to return a Subscription.
static Subscription	RxJavaHooks.onSingleReturn(Subscription subscription)	Hook to call before the Single.subscribe() method is about to return a Subscription.
<T> Subscription	RxJavaObservableExecutionHook.onSubscribeReturn(Subscription subscription)	Deprecated.
<T> Subscription	RxJavaSingleExecutionHook.onSubscribeReturn(Subscription subscription)	Deprecated.

Method parameters in rx.plugins with type arguments of type Subscription

Modifier and Type	Method	Description
static void	RxJavaHooks.setOnObservableReturn(Func1<Subscription,Subscription> onObservableReturn)	Sets a hook function that is called when the Observable.subscribe() call is about to return a Subscription unless a lockdown is in effect.
static void	RxJavaHooks.setOnObservableReturn(Func1<Subscription,Subscription> onObservableReturn)	Sets a hook function that is called when the Observable.subscribe() call is about to return a Subscription unless a lockdown is in effect.
static void	RxJavaHooks.setOnSingleReturn(Func1<Subscription,Subscription> onSingleReturn)	Sets a hook function that is called when the Single.subscribe() call is about to return a Subscription unless a lockdown is in effect.
static void	RxJavaHooks.setOnSingleReturn(Func1<Subscription,Subscription> onSingleReturn)	Sets a hook function that is called when the Single.subscribe() call is about to return a Subscription unless a lockdown is in effect.

Uses of Subscription in rx.schedulers

Classes in rx.schedulers that implement Subscription

Modifier and Type	Class	Description
(package private) final class	TestScheduler.InnerTestScheduler

Methods in rx.schedulers that return Subscription

Modifier and Type	Method	Description
Subscription	TestScheduler.InnerTestScheduler.schedule(Action0 action)
Subscription	TestScheduler.InnerTestScheduler.schedule(Action0 action, long delayTime, TimeUnit unit)

Uses of Subscription in rx.subjects

Classes in rx.subjects that implement Subscription

Modifier and Type	Class	Description
(package private) static final class	ReplaySubject.ReplayProducer<T>	A producer and subscription implementation that tracks the current replay position of a particular subscriber.
(package private) static final class	UnicastSubject.State<T>	The single-consumption replaying state.

Uses of Subscription in rx.subscriptions

Classes in rx.subscriptions that implement Subscription

Modifier and Type	Class	Description
final class	BooleanSubscription	Subscription that can be checked for status such as in a loop inside an Observable to exit the loop if unsubscribed.
final class	CompositeSubscription	Subscription that represents a group of Subscriptions that are unsubscribed together.
final class	MultipleAssignmentSubscription	Subscription that can be checked for status such as in a loop inside an Observable to exit the loop if unsubscribed.
final class	RefCountSubscription	Keeps track of the sub-subscriptions and unsubscribes the underlying subscription once all sub-subscriptions have unsubscribed.
(package private) static final class	RefCountSubscription.InnerSubscription	The individual sub-subscriptions.
final class	SerialSubscription	Represents a subscription whose underlying subscription can be swapped for another subscription which causes the previous underlying subscription to be unsubscribed.
(package private) static final class	Subscriptions.FutureSubscription	Naming classes helps with debugging.
(package private) static final class	Subscriptions.Unsubscribed	Naming classes helps with debugging.

Fields in rx.subscriptions declared as Subscription

Modifier and Type	Field	Description
private final Subscription	RefCountSubscription.actual
(package private) final Subscription	MultipleAssignmentSubscription.State.subscription
(package private) final Subscription	SerialSubscription.State.subscription

Fields in rx.subscriptions with type parameters of type Subscription

Modifier and Type	Field	Description
private Set<Subscription>	CompositeSubscription.subscriptions

Methods in rx.subscriptions that return Subscription

Modifier and Type	Method	Description
static Subscription	Subscriptions.create(Action0 unsubscribe)	Creates and returns a Subscription that invokes the given Action0 when unsubscribed.
static Subscription	Subscriptions.empty()	Returns a Subscription to which unsubscribe does nothing except to change isUnsubscribed to true.
static Subscription	Subscriptions.from(Future<?> f)	Converts a Future into a Subscription and cancels it when unsubscribed.
Subscription	MultipleAssignmentSubscription.get()	Gets the underlying subscription.
Subscription	RefCountSubscription.get()	Returns a new sub-subscription
Subscription	SerialSubscription.get()	Retrieves the current Subscription that is being represented by this SerialSubscription.
static Subscription	Subscriptions.unsubscribed()	Returns a Subscription to which unsubscribe does nothing, as it is already unsubscribed.

Methods in rx.subscriptions with parameters of type Subscription

Modifier and Type	Method	Description
void	CompositeSubscription.add(Subscription s)	Adds a new Subscription to this CompositeSubscription if the CompositeSubscription is not yet unsubscribed.
void	CompositeSubscription.addAll(Subscription... subscriptions)	Adds collection of Subscription to this CompositeSubscription if the CompositeSubscription is not yet unsubscribed.
static CompositeSubscription	Subscriptions.from(Subscription... subscriptions)	Converts a set of Subscriptions into a CompositeSubscription that groups the multiple Subscriptions together and unsubscribes from all of them together.
void	CompositeSubscription.remove(Subscription s)	Removes a Subscription from this CompositeSubscription, and unsubscribes the Subscription.
void	MultipleAssignmentSubscription.set(Subscription s)	Sets the underlying subscription.
(package private) MultipleAssignmentSubscription.State	MultipleAssignmentSubscription.State.set(Subscription s)
void	SerialSubscription.set(Subscription s)	Swaps out the old Subscription for the specified Subscription.
(package private) SerialSubscription.State	SerialSubscription.State.set(Subscription s)

Method parameters in rx.subscriptions with type arguments of type Subscription

Modifier and Type	Method	Description
private static void	CompositeSubscription.unsubscribeFromAll(Collection<Subscription> subscriptions)

Constructors in rx.subscriptions with parameters of type Subscription

Modifier	Constructor	Description
	CompositeSubscription(Subscription... subscriptions)
	RefCountSubscription(Subscription s)	Creates a RefCountSubscription by wrapping the given non-null Subscription.
(package private)	State(boolean u, Subscription s)
(package private)	State(boolean u, Subscription s)