Skip to content

Commit fd4b614

Browse files
UMFsimkeakarnokd
authored andcommitted
Single error operators marbles (#6086)
* Add marbles for Single.error operators * Add marbles for Single.onError operators * Use proper URLs for marble diagrams
1 parent 396f2f6 commit fd4b614

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

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

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -507,6 +507,8 @@ public static <T> Single<T> defer(final Callable<? extends SingleSource<? extend
507507

508508
/**
509509
* Signals a Throwable returned by the callback function for each individual SingleObserver.
510+
* <p>
511+
* <img width="640" height="283" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.error.c.png" alt="">
510512
* <dl>
511513
* <dt><b>Scheduler:</b></dt>
512514
* <dd>{@code error} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -527,7 +529,7 @@ public static <T> Single<T> error(final Callable<? extends Throwable> errorSuppl
527529
* Returns a Single that invokes a subscriber's {@link SingleObserver#onError onError} method when the
528530
* subscriber subscribes to it.
529531
* <p>
530-
* <img width="640" height="190" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.error.png" alt="">
532+
* <img width="640" height="283" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.error.png" alt="">
531533
* <dl>
532534
* <dt><b>Scheduler:</b></dt>
533535
* <dd>{@code error} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -2921,7 +2923,7 @@ public final Single<T> observeOn(final Scheduler scheduler) {
29212923
* Instructs a Single to emit an item (returned by a specified function) rather than invoking
29222924
* {@link SingleObserver#onError onError} if it encounters an error.
29232925
* <p>
2924-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.onErrorReturn.png" alt="">
2926+
* <img width="640" height="451" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.onErrorReturn.png" alt="">
29252927
* <p>
29262928
* By default, when a Single encounters an error that prevents it from emitting the expected item to its
29272929
* subscriber, the Single invokes its subscriber's {@link SingleObserver#onError} method, and then quits
@@ -2952,6 +2954,8 @@ public final Single<T> onErrorReturn(final Function<Throwable, ? extends T> resu
29522954

29532955
/**
29542956
* Signals the specified value as success in case the current Single signals an error.
2957+
* <p>
2958+
* <img width="640" height="451" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.onErrorReturnItem.png" alt="">
29552959
* <dl>
29562960
* <dt><b>Scheduler:</b></dt>
29572961
* <dd>{@code onErrorReturnItem} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -2971,7 +2975,7 @@ public final Single<T> onErrorReturnItem(final T value) {
29712975
* Instructs a Single to pass control to another Single rather than invoking
29722976
* {@link SingleObserver#onError(Throwable)} if it encounters an error.
29732977
* <p>
2974-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/onErrorResumeNext.png" alt="">
2978+
* <img width="640" height="451" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.onErrorResumeNext.png" alt="">
29752979
* <p>
29762980
* By default, when a Single encounters an error that prevents it from emitting the expected item to
29772981
* its {@link SingleObserver}, the Single invokes its SingleObserver's {@code onError} method, and then quits
@@ -3005,7 +3009,7 @@ public final Single<T> onErrorResumeNext(final Single<? extends T> resumeSingleI
30053009
* Instructs a Single to pass control to another Single rather than invoking
30063010
* {@link SingleObserver#onError(Throwable)} if it encounters an error.
30073011
* <p>
3008-
* <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/onErrorResumeNext.png" alt="">
3012+
* <img width="640" height="451" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.onErrorResumeNext.f.png" alt="">
30093013
* <p>
30103014
* By default, when a Single encounters an error that prevents it from emitting the expected item to
30113015
* its {@link SingleObserver}, the Single invokes its SingleObserver's {@code onError} method, and then quits

0 commit comments

Comments
 (0)