rx.internal.operators

Class OnSubscribeDefer<T>

  • 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.

    • Constructor Detail

      • OnSubscribeDefer

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