Package rx.subscriptions

Class Subscriptions

java.lang.Object

rx.subscriptions.Subscriptions

public final class Subscriptions
extends java.lang.Object

Helper methods and utilities for creating and working with Subscription objects

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	Subscriptions.FutureSubscription	Naming classes helps with debugging.
(package private) static class	Subscriptions.Unsubscribed	Naming classes helps with debugging.

Field Summary

Fields

Modifier and Type	Field	Description
private static Subscriptions.Unsubscribed	UNSUBSCRIBED	A Subscription that does nothing when its unsubscribe method is called.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Subscriptions()

Method Summary

Modifier and Type	Method	Description
static Subscription	create(Action0 unsubscribe)	Creates and returns a Subscription that invokes the given Action0 when unsubscribed.
static Subscription	empty()	Returns a Subscription to which unsubscribe does nothing except to change isUnsubscribed to true.
static Subscription	from(java.util.concurrent.Future<?> f)	Converts a Future into a Subscription and cancels it when unsubscribed.
static CompositeSubscription	from(Subscription... subscriptions)	Converts a set of Subscriptions into a CompositeSubscription that groups the multiple Subscriptions together and unsubscribes from all of them together.
static Subscription	unsubscribed()	Returns a Subscription to which unsubscribe does nothing, as it is already unsubscribed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

UNSUBSCRIBED

private static final Subscriptions.Unsubscribed UNSUBSCRIBED

A Subscription that does nothing when its unsubscribe method is called.

Constructor Detail

Subscriptions

private Subscriptions()

Method Detail

empty

public static Subscription empty()

Returns a Subscription to which unsubscribe does nothing except to change isUnsubscribed to true. It's stateful and isUnsubscribed indicates if unsubscribe is called, which is different from unsubscribed().

 Subscription empty = Subscriptions.empty();
 System.out.println(empty.isUnsubscribed()); // false
 empty.unsubscribe();
 System.out.println(empty.isUnsubscribed()); // true
 

Returns:

a Subscription to which unsubscribe does nothing except to change isUnsubscribed to true

unsubscribed

public static Subscription unsubscribed()

Returns a Subscription to which unsubscribe does nothing, as it is already unsubscribed. Its isUnsubscribed always returns true, which is different from empty().

 Subscription unsubscribed = Subscriptions.unsubscribed();
 System.out.println(unsubscribed.isUnsubscribed()); // true
 

Returns:

a Subscription to which unsubscribe does nothing, as it is already unsubscribed

Since:

1.1.0

create

public static Subscription create(Action0 unsubscribe)

Creates and returns a Subscription that invokes the given Action0 when unsubscribed.

Parameters:

unsubscribe - Action to invoke on unsubscribe.

Returns:

Subscription

from

public static Subscription from(java.util.concurrent.Future<?> f)

Converts a Future into a Subscription and cancels it when unsubscribed.

Parameters:

f - the Future to convert

Returns:

a Subscription that wraps f

from

public static CompositeSubscription from(Subscription... subscriptions)

Converts a set of Subscriptions into a CompositeSubscription that groups the multiple Subscriptions together and unsubscribes from all of them together.

Parameters:

subscriptions - the Subscriptions to group together

Returns:

a CompositeSubscription representing the subscriptions set