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	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	Observable.subscribe() Subscribes to an Observable but ignore its emissions and notifications.
  Subscription	Observable.subscribe(Action1<? super T> onNext) Subscribes to an Observable and provides a callback to handle the items it emits.
  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	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.

• Uses of Subscription in rx.internal.operators

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

  Modifier and Type	Method and Description
  void	OperatorPublish.connect(Action1<? super Subscription> connection)
  void	OperatorMulticast.connect(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)

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

  Modifier and Type	Method and Description
  void	ScheduledAction.add(Subscription s)

• Uses of Subscription in rx.internal.util

  Classes in with type parameters of type

  Modifier and Type	Class and Description
  class	SubscriptionIndexedRingBuffer<T extends Subscription> Similar to CompositeSubscription but giving extra access to internals so we can reuse a datastructure.
  class	SubscriptionRandomList<T extends Subscription> Subscription that represents a group of Subscriptions that are unsubscribed together.

  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	SubscriptionIndexedRingBuffer<T extends Subscription> Similar to CompositeSubscription but giving extra access to internals so we can reuse a datastructure.
  class	SubscriptionList Subscription that represents a group of Subscriptions that are unsubscribed together.
  class	SubscriptionRandomList<T extends Subscription> 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.
  void	SubscriptionRandomList.remove(Subscription s) Removes a Subscription from this CompositeSubscription, and unsubscribes the Subscription.

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

  Constructor and Description
  	SubscriptionIndexedRingBuffer(T... subscriptions)
  	SubscriptionList(Subscription... subscriptions)
  	SubscriptionRandomList(T... subscriptions)
  	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
  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 Rx 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 that does nothing.
  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.

  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.