rx.internal.operators

Class OnSubscribeFromCallable<T>

  • All Implemented Interfaces:
    Action, Action1<Subscriber<? super T>>, Function, Observable.OnSubscribe<T> 

    public final class OnSubscribeFromCallable<T>
extends Object
implements Observable.OnSubscribe<T>
    Do not invoke the function until an Observer subscribes; Invokes function on each subscription.

    Pass fromCallable a function, and fromCallable will call this function to emit result of invocation afresh each time a new Observer subscribes.

    • Constructor Detail

      • OnSubscribeFromCallable

        public OnSubscribeFromCallable(Callable<? extends T> resultFactory)

    • Method Detail

      • call

        public void call(Subscriber<? super T> subscriber)