T
- the value typepublic final class OnSubscribeDefer<T> extends Object implements Observable.OnSubscribe<T>
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 and Description |
---|
OnSubscribeDefer(Func0<? extends Observable<? extends T>> observableFactory) |
public OnSubscribeDefer(Func0<? extends Observable<? extends T>> observableFactory)
public void call(Subscriber<? super T> s)
call
in interface Action1<Subscriber<? super T>>
Copyright © 2018. All rights reserved.