41
41
* in a sequential fashion following this protocol:<br>
42
42
* {@code onSubscribe (onSuccess | onError | onComplete)?}.
43
43
* <p>
44
+ * Note that {@code onSuccess}, {@code onError} and {@code onComplete} are mutually exclusive events; unlike {@code Observable},
45
+ * {@code onSuccess} is never followed by {@code onError} or {@code onComplete}.
44
46
* @param <T> the value type
45
47
* @since 2.0
46
48
*/
@@ -2489,7 +2491,7 @@ public final Maybe<T> doOnDispose(Action onDispose) {
2489
2491
/**
2490
2492
* Modifies the source Maybe so that it invokes an action when it calls {@code onComplete}.
2491
2493
* <p>
2492
- * <img width="640" height="305 " src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/doOnComplete.png" alt="">
2494
+ * <img width="640" height="358 " src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/doOnComplete.m .png" alt="">
2493
2495
* <dl>
2494
2496
* <dt><b>Scheduler:</b></dt>
2495
2497
* <dd>{@code doOnComplete} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -2516,6 +2518,8 @@ public final Maybe<T> doOnComplete(Action onComplete) {
2516
2518
/**
2517
2519
* Calls the shared consumer with the error sent via onError for each
2518
2520
* MaybeObserver that subscribes to the current Maybe.
2521
+ * <p>
2522
+ * <img width="640" height="358" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/doOnError.m.png" alt="">
2519
2523
* <dl>
2520
2524
* <dt><b>Scheduler:</b></dt>
2521
2525
* <dd>{@code doOnError} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -2583,6 +2587,8 @@ public final Maybe<T> doOnSubscribe(Consumer<? super Disposable> onSubscribe) {
2583
2587
/**
2584
2588
* Calls the shared consumer with the success value sent via onSuccess for each
2585
2589
* MaybeObserver that subscribes to the current Maybe.
2590
+ * <p>
2591
+ * <img width="640" height="358" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/doOnSuccess.m.png" alt="">
2586
2592
* <dl>
2587
2593
* <dt><b>Scheduler:</b></dt>
2588
2594
* <dd>{@code doOnSuccess} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -2653,7 +2659,7 @@ public final <R> Maybe<R> flatMap(Function<? super T, ? extends MaybeSource<? ex
2653
2659
2654
2660
/**
2655
2661
* Maps the onSuccess, onError or onComplete signals of this Maybe into MaybeSource and emits that
2656
- * MaybeSource's signals
2662
+ * MaybeSource's signals.
2657
2663
* <p>
2658
2664
* <img width="640" height="410" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMap.nce.png" alt="">
2659
2665
* <dl>
@@ -4140,7 +4146,7 @@ public final <U> Maybe<T> timeout(Publisher<U> timeoutIndicator, MaybeSource<? e
4140
4146
4141
4147
/**
4142
4148
* Returns a Maybe which makes sure when a MaybeObserver disposes the Disposable,
4143
- * that call is propagated up on the specified scheduler
4149
+ * that call is propagated up on the specified scheduler.
4144
4150
* <dl>
4145
4151
* <dt><b>Scheduler:</b></dt>
4146
4152
* <dd>{@code unsubscribeOn} calls dispose() of the upstream on the {@link Scheduler} you specify.</dd>
0 commit comments