Class OnSubscribeFromCallable<T>

java.lang.Object
rx.internal.operators.OnSubscribeFromCallable<T>
Type Parameters:
T - the value type emitted
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.

  • Field Details

    • resultFactory

      private final Callable<? extends T> resultFactory
  • Constructor Details

    • OnSubscribeFromCallable

      public OnSubscribeFromCallable(Callable<? extends T> resultFactory)
  • Method Details