Package rx.internal.operators

Class SingleOnSubscribeMap.MapSubscriber<T,R>

java.lang.Object

rx.SingleSubscriber<T>

rx.internal.operators.SingleOnSubscribeMap.MapSubscriber<T,R>

All Implemented Interfaces:

Subscription

Enclosing class:

SingleOnSubscribeMap<T,R>

static final class SingleOnSubscribeMap.MapSubscriber<T,R>
extends SingleSubscriber<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final SingleSubscriber<? super R>	actual
(package private) boolean	done
(package private) final Func1<? super T,? extends R>	mapper

Constructor Summary

Constructors

Constructor	Description
MapSubscriber(SingleSubscriber<? super R> actual, Func1<? super T,? extends R> mapper)

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 R> actual

mapper

final Func1<? super T,? extends R> mapper

done

boolean done

Constructor Details

MapSubscriber

public MapSubscriber(SingleSubscriber<? super R> actual,
 Func1<? super T,? extends R> mapper)

Method Details

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

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