Top Description Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeFromCallable<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 emitted
Imports
java.util.concurrent.Callable, rx.*, rx.exceptions.Exceptions, rx.internal.producers.SingleDelayedProducer
Do not invoke the function until an Observer subscribes; Invokes function on each subscription.

Pass fromCallable a function, and fromCallable will call this function to emit result of invocation afresh each time a new Observer subscribes.

Field Summary

Modifier and TypeField and Description
private final Callable<? extends T>
resultFactory

Constructor Summary

AccessConstructor and Description
public
OnSubscribeFromCallable(Callable<? extends T> resultFactory)

Method Summary

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

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

resultFactoryback to summary
private final Callable<? extends T> resultFactory

Constructor Detail

OnSubscribeFromCallableback to summary
public OnSubscribeFromCallable(Callable<? extends T> resultFactory)

Method Detail

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

Implements rx.functions.Action1.call.

Annotations
@Override