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

      • observableFactory

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

      • OnSubscribeDefer

        public OnSubscribeDefer​(Func0<? extends Observable<? extends T>> observableFactory)