Top Description Inners Fields Constructors Methods
rx.internal.operators

public final Class SingleLiftObservableOperator<T, R>

extends Object
implements Single.OnSubscribe<R>
Class Inheritance
All Implemented Interfaces
rx.Single.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the input value type
<R>
the output value type
Imports
rx.*, .Observable.Operator, .Single.OnSubscribe, rx.exceptions.Exceptions, rx.internal.operators.SingleFromObservable.WrapSingleIntoSubscriber, rx.internal.producers.SingleProducer, rx.plugins.RxJavaHooks
Lift an Observable.Operator into the Single sequence.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
SingleLiftObservableOperator.WrapSubscriberIntoSingle<T>

Field Summary

Modifier and TypeField and Description
pack-priv final Observable.Operator<? extends R, ? super T>
lift

pack-priv final Single.OnSubscribe<T>
source

Constructor Summary

AccessConstructor and Description
public
SingleLiftObservableOperator(Single.OnSubscribe<T> source, Observable.Operator<? extends R, ? super T> lift)

Method Summary

Modifier and TypeMethod and Description
public void
call(SingleSubscriber<? super R> t)

Implements rx.functions.Action1.call.

public static <T> SingleSubscriber<T>
wrap(Subscriber<T> subscriber)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

liftback to summary
pack-priv final Observable.Operator<? extends R, ? super T> lift
sourceback to summary
pack-priv final Single.OnSubscribe<T> source

Constructor Detail

SingleLiftObservableOperatorback to summary
public SingleLiftObservableOperator(Single.OnSubscribe<T> source, Observable.Operator<? extends R, ? super T> lift)

Method Detail

callback to summary
public void call(SingleSubscriber<? super R> t)

Implements rx.functions.Action1.call.

Annotations
@Override
wrapback to summary
public static <T> SingleSubscriber<T> wrap(Subscriber<T> subscriber)
rx.internal.operators back to summary

pack-priv final Class SingleLiftObservableOperator.WrapSubscriberIntoSingle<T>

extends SingleSubscriber<T>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final Subscriber<? super T>
actual

Constructor Summary

AccessConstructor and Description
pack-priv
WrapSubscriberIntoSingle(Subscriber<? super T> actual)

Method Summary

Modifier and TypeMethod and Description
public void
onError(Throwable
the exception encountered by the Single
error)

Implements abstract rx.SingleSubscriber.onError.

Notifies the SingleSubscriber that the Single has experienced an error condition.
public void
onSuccess(T
the item emitted by the Single
value)

Implements abstract rx.SingleSubscriber.onSuccess.

Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.
Inherited from rx.SingleSubscriber:
addisUnsubscribedunsubscribe

Field Detail

actualback to summary
pack-priv final Subscriber<? super T> actual

Constructor Detail

WrapSubscriberIntoSingleback to summary
pack-priv WrapSubscriberIntoSingle(Subscriber<? super T> actual)

Method Detail

onErrorback to summary
public void onError(Throwable error)

Implements abstract rx.SingleSubscriber.onError.

Doc from rx.SingleSubscriber.onError.

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

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

Parameters
error:Throwable

the exception encountered by the Single

Annotations
@Override
onSuccessback to summary
public void onSuccess(T value)

Implements abstract rx.SingleSubscriber.onSuccess.

Doc from rx.SingleSubscriber.onSuccess.

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.

Parameters
value:T

the item emitted by the Single

Annotations
@Override