Package rx.internal.operators

Class OnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber<T>

java.lang.Object

rx.SingleSubscriber<T>

rx.internal.operators.OnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber<T>

All Implemented Interfaces:

Subscription

Enclosing class:

OnSubscribeOnAssemblySingle<T>

static final class OnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber<T>
extends SingleSubscriber<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final SingleSubscriber<? super T>	actual
(package private) final String	stacktrace

Constructor Summary

Constructors

Constructor	Description
OnAssemblySingleSubscriber(SingleSubscriber<? super T> actual, String stacktrace)

Method Summary

Modifier and Type	Method	Description
void	onError(Throwable e)	Notifies the SingleSubscriber that the Single has experienced an error condition.
void	onSuccess(T t)	Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.

Methods inherited from class rx.SingleSubscriber

add, isUnsubscribed, unsubscribe

Methods inherited from class java.lang.Object

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

Field Details

actual

final SingleSubscriber<? super T> actual

stacktrace

final String stacktrace

Constructor Details

OnAssemblySingleSubscriber

public OnAssemblySingleSubscriber(SingleSubscriber<? super T> actual,
 String stacktrace)

Method Details

onError

public void onError(Throwable e)

Description copied from class: SingleSubscriber

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

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

Specified by:

onError in class SingleSubscriber<T>

Parameters:

e - the exception encountered by the Single

onSuccess

public void onSuccess(T t)

Description copied from class: SingleSubscriber

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 SingleSubscriber.onError(java.lang.Throwable).

Specified by:

onSuccess in class SingleSubscriber<T>

Parameters:

t - the item emitted by the Single