Top Description Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeDefer<T>

extends Object
implements Observable.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the value type
Imports
rx.*, .Observable.OnSubscribe, rx.exceptions.Exceptions, rx.functions.Func0, rx.observers.Subscribers
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

Modifier and TypeField and Description
pack-priv final Func0<? extends Observable<? extends T>>
observableFactory

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
public void
call(final Subscriber<? super T> s)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

observableFactoryback to summary
pack-priv final Func0<? extends Observable<? extends T>> observableFactory

Constructor Detail

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

Method Detail

callback to summary
public void call(final Subscriber<? super T> s)

Implements rx.functions.Action1.call.

Annotations
@Override