Skip to content

Commit e3b695a

Browse files
authored
3.x: add marbles to X.fromSupplier (#6531)
1 parent e13874d commit e3b695a

File tree

5 files changed

+6
-4
lines changed

5 files changed

+6
-4
lines changed

src/main/java/io/reactivex/Completable.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -615,7 +615,7 @@ public static <T> Completable fromSingle(final SingleSource<T> single) {
615615
* Returns a Completable which when subscribed, executes the supplier function, ignores its
616616
* normal result and emits onError or onComplete only.
617617
* <p>
618-
* <img width="640" height="286" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.fromCallable.png" alt="">
618+
* <img width="640" height="286" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.fromSupplier.png" alt="">
619619
* <dl>
620620
* <dt><b>Scheduler:</b></dt>
621621
* <dd>{@code fromSupplier} does not operate by default on a particular {@link Scheduler}.</dd>

src/main/java/io/reactivex/Flowable.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -2336,7 +2336,7 @@ public static <T> Flowable<T> fromPublisher(final Publisher<? extends T> source)
23362336
* Returns a Flowable that, when a Subscriber subscribes to it, invokes a supplier function you specify and then
23372337
* emits the value returned from that function.
23382338
* <p>
2339-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/fromCallable.png" alt="">
2339+
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Flowable.fromSupplier.png" alt="">
23402340
* <p>
23412341
* This allows you to defer the execution of the function you specify until a Subscriber subscribes to the
23422342
* Publisher. That is to say, it makes the function "lazy."

src/main/java/io/reactivex/Maybe.java

+2
Original file line numberDiff line numberDiff line change
@@ -877,6 +877,8 @@ public static <T> Maybe<T> fromRunnable(final Runnable run) {
877877
* subscribes to the returned {@link Maybe}. In other terms, this source operator evaluates the given
878878
* {@code Supplier} "lazily".
879879
* <p>
880+
* <img width="640" height="311" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Maybe.fromSupplier.png" alt="">
881+
* <p>
880882
* Note that the {@code null} handling of this operator differs from the similar source operators in the other
881883
* {@link io.reactivex base reactive classes}. Those operators signal a {@code NullPointerException} if the value returned by their
882884
* {@code Supplier} is {@code null} while this {@code fromSupplier} considers it to indicate the

src/main/java/io/reactivex/Observable.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -2026,7 +2026,7 @@ public static <T> Observable<T> fromPublisher(Publisher<? extends T> publisher)
20262026
* Returns an Observable that, when an observer subscribes to it, invokes a supplier function you specify and then
20272027
* emits the value returned from that function.
20282028
* <p>
2029-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/fromCallable.png" alt="">
2029+
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Observable.fromSupplier.png" alt="">
20302030
* <p>
20312031
* This allows you to defer the execution of the function you specify until an observer subscribes to the
20322032
* ObservableSource. That is to say, it makes the function "lazy."

src/main/java/io/reactivex/Single.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -821,7 +821,7 @@ public static <T> Single<T> fromObservable(ObservableSource<? extends T> observa
821821
* It makes passed function "lazy".
822822
* Result of the function invocation will be emitted by the {@link Single}.
823823
* <p>
824-
* <img width="640" height="467" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.fromCallable.png" alt="">
824+
* <img width="640" height="467" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.fromSupplier.png" alt="">
825825
* <dl>
826826
* <dt><b>Scheduler:</b></dt>
827827
* <dd>{@code fromSupplier} does not operate by default on a particular {@link Scheduler}.</dd>

0 commit comments

Comments
 (0)