Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

2.x: Add marbles for Observable (12/06) #5755

Merged
merged 1 commit into from
Dec 7, 2017
Merged

2.x: Add marbles for Observable (12/06) #5755

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
26 changes: 24 additions & 2 deletions src/main/java/io/reactivex/Observable.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6121,7 +6121,8 @@ public final <R> Observable<R> concatMap(Function<? super T, ? extends Observabl
* one at a time and emits their values in order
* while delaying any error from either this or any of the inner ObservableSources
* till all of them terminate.
*
* <p>
* <img width="640" height="347" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapDelayError.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code concatMapDelayError} does not operate by default on a particular {@link Scheduler}.</dd>
Expand All @@ -6142,7 +6143,8 @@ public final <R> Observable<R> concatMapDelayError(Function<? super T, ? extends
* one at a time and emits their values in order
* while delaying any error from either this or any of the inner ObservableSources
* till all of them terminate.
*
* <p>
* <img width="640" height="347" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapDelayError.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code concatMapDelayError} does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down Expand Up @@ -6181,6 +6183,8 @@ public final <R> Observable<R> concatMapDelayError(Function<? super T, ? extends
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
* source ObservableSources. The operator buffers the values emitted by these ObservableSources and then drains them in
* order, each one after the previous one completes.
* <p>
* <img width="640" height="360" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapEager.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>This method does not operate by default on a particular {@link Scheduler}.</dd>
Expand All @@ -6204,6 +6208,8 @@ public final <R> Observable<R> concatMapEager(Function<? super T, ? extends Obse
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
* source ObservableSources. The operator buffers the values emitted by these ObservableSources and then drains them in
* order, each one after the previous one completes.
* <p>
* <img width="640" height="360" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapEager.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>This method does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down Expand Up @@ -6233,6 +6239,8 @@ public final <R> Observable<R> concatMapEager(Function<? super T, ? extends Obse
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
* source ObservableSources. The operator buffers the values emitted by these ObservableSources and then drains them in
* order, each one after the previous one completes.
* <p>
* <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapEagerDelayError.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>This method does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down Expand Up @@ -6260,6 +6268,8 @@ public final <R> Observable<R> concatMapEagerDelayError(Function<? super T, ? ex
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
* source ObservableSources. The operator buffers the values emitted by these ObservableSources and then drains them in
* order, each one after the previous one completes.
* <p>
* <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapEagerDelayError.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>This method does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down Expand Up @@ -6290,6 +6300,8 @@ public final <R> Observable<R> concatMapEagerDelayError(Function<? super T, ? ex
/**
* Maps each element of the upstream Observable into CompletableSources, subscribes to them one at a time in
* order and waits until the upstream and all CompletableSources complete.
* <p>
* <img width="640" height="505" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapCompletable.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code concatMapCompletable} does not operate by default on a particular {@link Scheduler}.</dd>
Expand All @@ -6310,6 +6322,8 @@ public final Completable concatMapCompletable(Function<? super T, ? extends Comp
/**
* Maps each element of the upstream Observable into CompletableSources, subscribes to them one at a time in
* order and waits until the upstream and all CompletableSources complete.
* <p>
* <img width="640" height="505" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapCompletable.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code concatMapCompletable} does not operate by default on a particular {@link Scheduler}.</dd>
Expand All @@ -6336,6 +6350,8 @@ public final Completable concatMapCompletable(Function<? super T, ? extends Comp
/**
* Returns an Observable that concatenate each item emitted by the source ObservableSource with the values in an
* Iterable corresponding to that item that is generated by a selector.
* <p>
* <img width="640" height="275" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapIterable.o.png" alt="">
*
* <dl>
* <dt><b>Scheduler:</b></dt>
Expand All @@ -6361,6 +6377,8 @@ public final <U> Observable<U> concatMapIterable(final Function<? super T, ? ext
/**
* Returns an Observable that concatenate each item emitted by the source ObservableSource with the values in an
* Iterable corresponding to that item that is generated by a selector.
* <p>
* <img width="640" height="275" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMapIterable.o.png" alt="">
*
* <dl>
* <dt><b>Scheduler:</b></dt>
Expand Down Expand Up @@ -6989,6 +7007,8 @@ public final Observable<T> distinctUntilChanged(BiPredicate<? super T, ? super T
* Calls the specified consumer with the current item after this item has been emitted to the downstream.
* <p>Note that the {@code onAfterNext} action is shared between subscriptions and as such
* should be thread-safe.
* <p>
* <img width="640" height="360" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/doAfterNext.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code doAfterNext} does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down Expand Up @@ -7038,6 +7058,8 @@ public final Observable<T> doAfterTerminate(Action onFinally) {
* is executed once per subscription.
* <p>Note that the {@code onFinally} action is shared between subscriptions and as such
* should be thread-safe.
* <p>
* <img width="640" height="281" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/doFinally.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code doFinally} does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down