Top Description Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeLift<T, R>

extends Object
implements Observable.OnSubscribe<R>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the source value type
<R>
the result value type
Imports
rx.Observable.*, .Subscriber, rx.exceptions.Exceptions, rx.plugins.RxJavaHooks
Transforms the downstream Subscriber into a Subscriber via an operator callback and calls the parent OnSubscribe.call() method with it.

Field Summary

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

pack-priv final Observable.OnSubscribe<T>
parent

Constructor Summary

AccessConstructor and Description
public
OnSubscribeLift(Observable.OnSubscribe<T> parent, Observable.Operator<? extends R, ? super T> operator)

Method Summary

Modifier and TypeMethod and Description
public void
call(Subscriber<? super R> o)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

operatorback to summary
pack-priv final Observable.Operator<? extends R, ? super T> operator
parentback to summary
pack-priv final Observable.OnSubscribe<T> parent

Constructor Detail

OnSubscribeLiftback to summary
public OnSubscribeLift(Observable.OnSubscribe<T> parent, Observable.Operator<? extends R, ? super T> operator)

Method Detail

callback to summary
public void call(Subscriber<? super R> o)

Implements rx.functions.Action1.call.

Annotations
@Override