Packages that use Subscription

• Uses of Subscription in rx

  Classes in that implement

  Modifier and Type	Class and 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 that return

  Modifier and Type	Method and 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.
  Subscription	Single.subscribe() Subscribes to a Single but ignore its emission or notification.
  Subscription	Observable.subscribe() Subscribes to an Observable and ignores onNext and onCompleted emissions.
  Subscription	Single.subscribe(Action1<? super T> onSuccess) Subscribes to a Single and provides a callback to handle the item it emits.
  Subscription	Observable.subscribe(Action1<? super T> onNext) Subscribes to an Observable and provides a callback to handle the items it emits.
  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.
  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.
  Subscription	Observable.subscribe(Action1<? super T> onNext, Action1<Throwable> onError, Action0 onComplete) Subscribes to an Observable and provides callbacks to handle the items it emits and any error or completion notification it issues.
  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.
  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.
  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.
  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.
  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.

  Methods in rx with parameters of type Subscription

  Modifier and Type	Method and Description
  void	Subscriber.add(Subscription s) Adds a Subscription to this Subscriber's list of subscriptions if this list is not marked as unsubscribed.
  void	SingleSubscriber.add(Subscription s) Adds a Subscription to this Subscriber's list of subscriptions if this list is not marked as unsubscribed.

• Uses of Subscription in rx.internal.operators

  Classes in that implement

  Modifier and Type	Class and Description
  static class	BlockingOperatorToIterator.SubscriberIterator<T>

  Method parameters in with type arguments of type

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

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

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

• Uses of Subscription in rx.internal.schedulers

  Classes in that implement

  Modifier and Type	Class and Description
  class	NewThreadWorker
  class	ScheduledAction A Runnable that executes an Action0 and can be cancelled.

  Methods in that return

  Modifier and Type	Method and Description
  Subscription	NewThreadWorker.schedule(Action0 action)
  Subscription	NewThreadWorker.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 and 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 that implement

  Modifier and Type	Class and Description
  class	IndexedRingBuffer<E> Add/Remove without object allocation (after initial construction).
  class	RxRingBuffer This assumes Spsc or Spmc usage.
  class	SubscriptionList Subscription that represents a group of Subscriptions that are unsubscribed together.
  class	SynchronizedSubscription

  Methods in with parameters of type

  Modifier and Type	Method and 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)

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

  Constructor and Description
  	SubscriptionList(Subscription... subscriptions)
  	SubscriptionList(Subscription s)
  	SynchronizedSubscription(Subscription s)

• Uses of Subscription in rx.observables

  Methods in that return

  Modifier and Type	Method and Description
  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 and 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 and Description
  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.

• Uses of Subscription in rx.plugins

  Methods in that return

  Modifier and Type	Method and Description
  <T> Subscription	RxJavaObservableExecutionHook.onSubscribeReturn(Subscription subscription) Invoked after successful execution of Observable.subscribe(rx.Subscriber) with returned Subscription.

  Methods in rx.plugins with parameters of type Subscription

  Modifier and Type	Method and Description
  <T> Subscription	RxJavaObservableExecutionHook.onSubscribeReturn(Subscription subscription) Invoked after successful execution of Observable.subscribe(rx.Subscriber) with returned Subscription.

• Uses of Subscription in rx.subscriptions

  Classes in that implement

  Modifier and Type	Class and Description
  class	BooleanSubscription Subscription that can be checked for status such as in a loop inside an Observable to exit the loop if unsubscribed.
  class	CompositeSubscription Subscription that represents a group of Subscriptions that are unsubscribed together.
  class	MultipleAssignmentSubscription Subscription that can be checked for status such as in a loop inside an Observable to exit the loop if unsubscribed.
  class	RefCountSubscription Keeps track of the sub-subscriptions and unsubscribes the underlying subscription once all sub-subscriptions have unsubscribed.
  class	SerialSubscription Represents a subscription whose underlying subscription can be swapped for another subscription which causes the previous underlying subscription to be unsubscribed.

  Methods in that return

  Modifier and Type	Method and 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	SerialSubscription.get() Retrieves the current Subscription that is being represented by this SerialSubscription.
  Subscription	RefCountSubscription.get() Returns a new sub-subscription
  Subscription	MultipleAssignmentSubscription.get() Gets the underlying subscription.
  static Subscription	Subscriptions.unsubscribed() Returns a Subscription to which unsubscribe does nothing, as it is already unsubscribed.

  Methods in with parameters of type

  Modifier and Type	Method and Description
  void	CompositeSubscription.add(Subscription s) Adds a new 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	SerialSubscription.set(Subscription s) Swaps out the old Subscription for the specified Subscription.
  void	MultipleAssignmentSubscription.set(Subscription s) Sets the underlying subscription.

  Constructors in rx.subscriptions with parameters of type Subscription

  Constructor and Description
  	CompositeSubscription(Subscription... subscriptions)
  	RefCountSubscription(Subscription s) Creates a RefCountSubscription by wrapping the given non-null Subscription.