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>
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
FieldsModifier and TypeFieldDescription(package private) final Func0
<? extends Observable<? extends T>> -
Constructor Summary
ConstructorsConstructorDescriptionOnSubscribeDefer
(Func0<? extends Observable<? extends T>> observableFactory) -
Method Summary