Package rx.internal.operators
Class SingleDoAfterTerminate.SingleDoAfterTerminateSubscriber<T>
- java.lang.Object
-
- rx.SingleSubscriber<T>
-
- rx.internal.operators.SingleDoAfterTerminate.SingleDoAfterTerminateSubscriber<T>
-
- All Implemented Interfaces:
Subscription
- Enclosing class:
- SingleDoAfterTerminate<T>
static final class SingleDoAfterTerminate.SingleDoAfterTerminateSubscriber<T> extends SingleSubscriber<T>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) Action0action(package private) SingleSubscriber<? super T>actual
-
Constructor Summary
Constructors Constructor Description SingleDoAfterTerminateSubscriber(SingleSubscriber<? super T> actual, Action0 action)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) voiddoAction()voidonError(java.lang.Throwable error)Notifies the SingleSubscriber that theSinglehas experienced an error condition.voidonSuccess(T value)Notifies the SingleSubscriber with a single item and that theSinglehas finished sending push-based notifications.-
Methods inherited from class rx.SingleSubscriber
add, isUnsubscribed, unsubscribe
-
-
-
-
Field Detail
-
actual
final SingleSubscriber<? super T> actual
-
action
final Action0 action
-
-
Constructor Detail
-
SingleDoAfterTerminateSubscriber
public SingleDoAfterTerminateSubscriber(SingleSubscriber<? super T> actual, Action0 action)
-
-
Method Detail
-
onSuccess
public void onSuccess(T value)
Description copied from class:SingleSubscriberNotifies the SingleSubscriber with a single item and that theSinglehas finished sending push-based notifications.The
Singlewill not call this method if it callsSingleSubscriber.onError(java.lang.Throwable).- Specified by:
onSuccessin classSingleSubscriber<T>- Parameters:
value- the item emitted by the Single
-
onError
public void onError(java.lang.Throwable error)
Description copied from class:SingleSubscriberNotifies the SingleSubscriber that theSinglehas experienced an error condition.If the
Singlecalls this method, it will not thereafter callSingleSubscriber.onSuccess(T).- Specified by:
onErrorin classSingleSubscriber<T>- Parameters:
error- the exception encountered by the Single
-
doAction
void doAction()
-
-