@@ -554,6 +554,8 @@ public static <T> Single<T> error(final Throwable exception) {
554
554
* Allows you to defer execution of passed function until SingleObserver subscribes to the {@link Single}.
555
555
* It makes passed function "lazy".
556
556
* Result of the function invocation will be emitted by the {@link Single}.
557
+ * <p>
558
+ * <img width="640" height="467" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.fromCallable.png" alt="">
557
559
* <dl>
558
560
* <dt><b>Scheduler:</b></dt>
559
561
* <dd>{@code fromCallable} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -714,6 +716,8 @@ public static <T> Single<T> fromFuture(Future<? extends T> future, Scheduler sch
714
716
* Note that even though {@link Publisher} appears to be a functional interface, it
715
717
* is not recommended to implement it through a lambda as the specification requires
716
718
* state management that is not achievable with a stateless lambda.
719
+ * <p>
720
+ * <img width="640" height="322" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.fromPublisher.png" alt="">
717
721
* <dl>
718
722
* <dt><b>Backpressure:</b></dt>
719
723
* <dd>The {@code publisher} is consumed in an unbounded fashion but will be cancelled
@@ -738,6 +742,8 @@ public static <T> Single<T> fromPublisher(final Publisher<? extends T> publisher
738
742
* Wraps a specific ObservableSource into a Single and signals its single element or error.
739
743
* <p>If the ObservableSource is empty, a NoSuchElementException is signalled.
740
744
* If the source has more than one element, an IndexOutOfBoundsException is signalled.
745
+ * <p>
746
+ * <img width="640" height="343" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.fromObservable.png" alt="">
741
747
* <dl>
742
748
* <dt><b>Scheduler:</b></dt>
743
749
* <dd>{@code fromObservable} does not operate by default on a particular {@link Scheduler}.</dd>
0 commit comments