rx

Class SingleSubscriber<T>

java.lang.Object

rx.SingleSubscriber<T>

Type Parameters:

T - the type of item the SingleSubscriber expects to observe

All Implemented Interfaces:

Subscription

public abstract class SingleSubscriber<T>
extends java.lang.Object
implements Subscription

Provides a mechanism for receiving push-based notifications.

After a SingleSubscriber calls a Single's subscribe method, the Single calls the SingleSubscriber's onSuccess(T) and onError(java.lang.Throwable) methods to provide notifications. A well-behaved Single will call a SingleSubscriber's onSuccess(T) method exactly once or the SingleSubscriber's onError(java.lang.Throwable) method exactly once.

Note, that if you want isUnsubscribed() to return true after onSuccess(T) or onError(java.lang.Throwable) invocation, you need to invoke unsubscribe() in these methods.

Since:

1.2

See Also:

ReactiveX documentation: Observable

Constructor Summary

Constructors

Constructor and Description
SingleSubscriber()

Method Summary

Modifier and Type	Method and Description
void	add(Subscription s) Adds a Subscription to this Subscriber's list of subscriptions if this list is not marked as unsubscribed.
boolean	isUnsubscribed() Indicates whether this Subscriber has unsubscribed from its list of subscriptions.
abstract void	onError(java.lang.Throwable error) Notifies the SingleSubscriber that the Single has experienced an error condition.
abstract void	onSuccess(T t) Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.
void	unsubscribe() Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleSubscriber

public SingleSubscriber()

Method Detail

onSuccess

public abstract void onSuccess(T t)

Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.

The Single will not call this method if it calls onError(java.lang.Throwable).

Parameters:

t - the item emitted by the Single

onError

public abstract void onError(java.lang.Throwable error)

Notifies the SingleSubscriber that the Single has experienced an error condition.

If the Single calls this method, it will not thereafter call onSuccess(T).

Parameters:

error - the exception encountered by the Single

add

public final void add(Subscription s)

Adds a Subscription to this Subscriber's list of subscriptions if this list is not marked as unsubscribed. If the list is marked as unsubscribed, add will indicate this by explicitly unsubscribing the new Subscription as well.

Parameters:

s - the Subscription to add

unsubscribe

public final void unsubscribe()

Description copied from interface: Subscription

Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.

This allows deregistering an Subscriber before it has finished receiving all events (i.e. before onCompleted is called).

Specified by:

unsubscribe in interface Subscription

isUnsubscribed

public final boolean isUnsubscribed()

Indicates whether this Subscriber has unsubscribed from its list of subscriptions.

Specified by:

isUnsubscribed in interface Subscription

Returns:

true if this Subscriber has unsubscribed from its subscriptions, false otherwise