Class OnSubscribeDefer<T>

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

public final class OnSubscribeDefer<T> extends Object implements Observable.OnSubscribe<T>
Do not create the Observable until an Observer subscribes; create a fresh Observable on each subscription.

Pass defer an Observable factory function (a function that generates Observables), and defer will return an Observable that will call this function to generate its Observable sequence afresh each time a new Observer subscribes.

  • Field Details

    • observableFactory

      final Func0<? extends Observable<? extends T>> observableFactory
  • Constructor Details

    • OnSubscribeDefer

      public OnSubscribeDefer(Func0<? extends Observable<? extends T>> observableFactory)
  • Method Details