Skip to content

Commit 0bab46d

Browse files
akarnokdakarnokd
authored
2.x: Add marbles for Observable (12/06) (#5755)
1 parent 53d5a23 commit 0bab46d

File tree

1 file changed

+24
-2
lines changed

1 file changed

+24
-2
lines changed

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

Lines changed: 24 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6121,7 +6121,8 @@ public final <R> Observable<R> concatMap(Function<? super T, ? extends Observabl
61216121
* one at a time and emits their values in order
61226122
* while delaying any error from either this or any of the inner ObservableSources
61236123
* till all of them terminate.
6124-
*
6124+
* <p>
6125+
* <img width="640" height="347" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapDelayError.o.png" alt="">
61256126
* <dl>
61266127
* <dt><b>Scheduler:</b></dt>
61276128
* <dd>{@code concatMapDelayError} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -6142,7 +6143,8 @@ public final <R> Observable<R> concatMapDelayError(Function<? super T, ? extends
61426143
* one at a time and emits their values in order
61436144
* while delaying any error from either this or any of the inner ObservableSources
61446145
* till all of them terminate.
6145-
*
6146+
* <p>
6147+
* <img width="640" height="347" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapDelayError.o.png" alt="">
61466148
* <dl>
61476149
* <dt><b>Scheduler:</b></dt>
61486150
* <dd>{@code concatMapDelayError} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -6181,6 +6183,8 @@ public final <R> Observable<R> concatMapDelayError(Function<? super T, ? extends
61816183
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
61826184
* source ObservableSources. The operator buffers the values emitted by these ObservableSources and then drains them in
61836185
* order, each one after the previous one completes.
6186+
* <p>
6187+
* <img width="640" height="360" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapEager.o.png" alt="">
61846188
* <dl>
61856189
* <dt><b>Scheduler:</b></dt>
61866190
* <dd>This method does not operate by default on a particular {@link Scheduler}.</dd>
@@ -6204,6 +6208,8 @@ public final <R> Observable<R> concatMapEager(Function<? super T, ? extends Obse
62046208
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
62056209
* source ObservableSources. The operator buffers the values emitted by these ObservableSources and then drains them in
62066210
* order, each one after the previous one completes.
6211+
* <p>
6212+
* <img width="640" height="360" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapEager.o.png" alt="">
62076213
* <dl>
62086214
* <dt><b>Scheduler:</b></dt>
62096215
* <dd>This method does not operate by default on a particular {@link Scheduler}.</dd>
@@ -6233,6 +6239,8 @@ public final <R> Observable<R> concatMapEager(Function<? super T, ? extends Obse
62336239
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
62346240
* source ObservableSources. The operator buffers the values emitted by these ObservableSources and then drains them in
62356241
* order, each one after the previous one completes.
6242+
* <p>
6243+
* <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapEagerDelayError.o.png" alt="">
62366244
* <dl>
62376245
* <dt><b>Scheduler:</b></dt>
62386246
* <dd>This method does not operate by default on a particular {@link Scheduler}.</dd>
@@ -6260,6 +6268,8 @@ public final <R> Observable<R> concatMapEagerDelayError(Function<? super T, ? ex
62606268
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
62616269
* source ObservableSources. The operator buffers the values emitted by these ObservableSources and then drains them in
62626270
* order, each one after the previous one completes.
6271+
* <p>
6272+
* <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapEagerDelayError.o.png" alt="">
62636273
* <dl>
62646274
* <dt><b>Scheduler:</b></dt>
62656275
* <dd>This method does not operate by default on a particular {@link Scheduler}.</dd>
@@ -6290,6 +6300,8 @@ public final <R> Observable<R> concatMapEagerDelayError(Function<? super T, ? ex
62906300
/**
62916301
* Maps each element of the upstream Observable into CompletableSources, subscribes to them one at a time in
62926302
* order and waits until the upstream and all CompletableSources complete.
6303+
* <p>
6304+
* <img width="640" height="505" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapCompletable.o.png" alt="">
62936305
* <dl>
62946306
* <dt><b>Scheduler:</b></dt>
62956307
* <dd>{@code concatMapCompletable} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -6310,6 +6322,8 @@ public final Completable concatMapCompletable(Function<? super T, ? extends Comp
63106322
/**
63116323
* Maps each element of the upstream Observable into CompletableSources, subscribes to them one at a time in
63126324
* order and waits until the upstream and all CompletableSources complete.
6325+
* <p>
6326+
* <img width="640" height="505" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapCompletable.o.png" alt="">
63136327
* <dl>
63146328
* <dt><b>Scheduler:</b></dt>
63156329
* <dd>{@code concatMapCompletable} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -6336,6 +6350,8 @@ public final Completable concatMapCompletable(Function<? super T, ? extends Comp
63366350
/**
63376351
* Returns an Observable that concatenate each item emitted by the source ObservableSource with the values in an
63386352
* Iterable corresponding to that item that is generated by a selector.
6353+
* <p>
6354+
* <img width="640" height="275" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapIterable.o.png" alt="">
63396355
*
63406356
* <dl>
63416357
* <dt><b>Scheduler:</b></dt>
@@ -6361,6 +6377,8 @@ public final <U> Observable<U> concatMapIterable(final Function<? super T, ? ext
63616377
/**
63626378
* Returns an Observable that concatenate each item emitted by the source ObservableSource with the values in an
63636379
* Iterable corresponding to that item that is generated by a selector.
6380+
* <p>
6381+
* <img width="640" height="275" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapIterable.o.png" alt="">
63646382
*
63656383
* <dl>
63666384
* <dt><b>Scheduler:</b></dt>
@@ -6989,6 +7007,8 @@ public final Observable<T> distinctUntilChanged(BiPredicate<? super T, ? super T
69897007
* Calls the specified consumer with the current item after this item has been emitted to the downstream.
69907008
* <p>Note that the {@code onAfterNext} action is shared between subscriptions and as such
69917009
* should be thread-safe.
7010+
* <p>
7011+
* <img width="640" height="360" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/doAfterNext.o.png" alt="">
69927012
* <dl>
69937013
* <dt><b>Scheduler:</b></dt>
69947014
* <dd>{@code doAfterNext} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -7038,6 +7058,8 @@ public final Observable<T> doAfterTerminate(Action onFinally) {
70387058
* is executed once per subscription.
70397059
* <p>Note that the {@code onFinally} action is shared between subscriptions and as such
70407060
* should be thread-safe.
7061+
* <p>
7062+
* <img width="640" height="281" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/doFinally.o.png" alt="">
70417063
* <dl>
70427064
* <dt><b>Scheduler:</b></dt>
70437065
* <dd>{@code doFinally} does not operate by default on a particular {@link Scheduler}.</dd>

0 commit comments

Comments
 (0)