Class OnSubscribeLift<T,R>

java.lang.Object
rx.internal.operators.OnSubscribeLift<T,R>
Type Parameters:
T - the source value type
R - the result value type
All Implemented Interfaces:
Action, Action1<Subscriber<? super R>>, Function, Observable.OnSubscribe<R>

public final class OnSubscribeLift<T,R> extends Object implements Observable.OnSubscribe<R>
Transforms the downstream Subscriber into a Subscriber via an operator callback and calls the parent OnSubscribe.call() method with it.