Class 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 java.lang.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.