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>
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionMapSubscriber
(SingleSubscriber<? super R> actual, Func1<? super T, ? extends R> mapper) -
Method Summary
Methods inherited from class rx.SingleSubscriber
add, isUnsubscribed, unsubscribe
-
Field Details
-
actual
-
mapper
-
done
boolean done
-
-
Constructor Details
-
MapSubscriber
-
-
Method Details
-
onSuccess
Description copied from class:SingleSubscriber
Notifies the SingleSubscriber with a single item and that theSingle
has finished sending push-based notifications.The
Single
will not call this method if it callsSingleSubscriber.onError(java.lang.Throwable)
.- Specified by:
onSuccess
in classSingleSubscriber<T>
- Parameters:
t
- the item emitted by the Single
-
onError
Description copied from class:SingleSubscriber
Notifies the SingleSubscriber that theSingle
has experienced an error condition.If the
Single
calls this method, it will not thereafter callSingleSubscriber.onSuccess(T)
.- Specified by:
onError
in classSingleSubscriber<T>
- Parameters:
e
- the exception encountered by the Single
-