Package rx.internal.operators
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 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 Summary
Fields Modifier and Type Field Description (package private) Func0<? extends Observable<? extends T>>
observableFactory
-
Constructor Summary
Constructors Constructor Description OnSubscribeDefer(Func0<? extends Observable<? extends T>> observableFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
call(Subscriber<? super T> s)
-
-
-
Field Detail
-
observableFactory
final Func0<? extends Observable<? extends T>> observableFactory
-
-
Constructor Detail
-
OnSubscribeDefer
public OnSubscribeDefer(Func0<? extends Observable<? extends T>> observableFactory)
-
-
Method Detail
-
call
public void call(Subscriber<? super T> s)
-
-