@@ -1251,22 +1251,26 @@ public final static <T> Observable<T> from(T[] array) {
1251
1251
}
1252
1252
1253
1253
/**
1254
- * Returns an Observable that invokes passed function and emits its result for each new Observer that subscribes.
1254
+ * Returns an Observable that, when an observer subscribes to it, invokes a function you specify and then
1255
+ * emits the value returned from that function.
1255
1256
* <p>
1256
- * Allows you to defer execution of passed function until Observer subscribes to the Observable.
1257
- * It makes passed function "lazy".
1258
- * Result of the function invocation will be emitted by the Observable.
1257
+ * <img width="640" height="195" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/fromCallable.png" alt="">
1258
+ * <p>
1259
+ * This allows you to defer the execution of the function you specify untl an observer subscribes to the
1260
+ * Observable. That is to say, it makes the function "lazy."
1259
1261
* <dl>
1260
1262
* <dt><b>Scheduler:</b></dt>
1261
1263
* <dd>{@code fromCallable} does not operate by default on a particular {@link Scheduler}.</dd>
1262
1264
* </dl>
1263
1265
*
1264
1266
* @param func
1265
- * function which execution should be deferred, it will be invoked when Observer will subscribe to the Observable
1267
+ * a function, the execution of which should be deferred; {@code fromCallable} will invoke this
1268
+ * function only when an observer subscribes to the Observable that {@code fromCallable} returns
1266
1269
* @param <T>
1267
1270
* the type of the item emitted by the Observable
1268
1271
* @return an Observable whose {@link Observer}s' subscriptions trigger an invocation of the given function
1269
1272
* @see #defer(Func0)
1273
+ * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
1270
1274
*/
1271
1275
@Experimental
1272
1276
public static <T> Observable<T> fromCallable(Callable<? extends T> func) {
0 commit comments