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

2.x: More marbles 01/08-a #5795

Merged
merged 1 commit into from
Jan 8, 2018
Merged

2.x: More marbles 01/08-a #5795

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
30 changes: 20 additions & 10 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 @@ -7805,8 +7805,8 @@ public final <R> Observable<R> flatMap(
* Returns an Observable that applies a function to each item emitted or notification raised by the source
* ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items,
* while limiting the maximum number of concurrent subscriptions to these ObservableSources.
* <!-- <p> -->
* <!-- <img width="640" height="410" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMap.nce.png" alt=""> -->
* <p>
* <img width="640" height="410" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMap.nce.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code flatMap} does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down Expand Up @@ -7939,8 +7939,8 @@ public final <U, R> Observable<R> flatMap(Function<? super T, ? extends Observab
* Returns an Observable that emits the results of a specified function to the pair of values emitted by the
* source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
* subscriptions to these ObservableSources.
* <!-- <p> -->
* <!-- <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMap.r.png" alt=""> -->
* <p>
* <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMap.r.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code flatMap} does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down Expand Up @@ -7976,8 +7976,8 @@ public final <U, R> Observable<R> flatMap(Function<? super T, ? extends Observab
* Returns an Observable that emits the results of a specified function to the pair of values emitted by the
* source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
* subscriptions to these ObservableSources.
* <!-- <p> -->
* <!-- <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMap.r.png" alt=""> -->
* <p>
* <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMap.r.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code flatMap} does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down Expand Up @@ -8017,8 +8017,8 @@ public final <U, R> Observable<R> flatMap(final Function<? super T, ? extends Ob
* Returns an Observable that emits the results of a specified function to the pair of values emitted by the
* source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
* subscriptions to these ObservableSources.
* <!-- <p> -->
* <!-- <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMap.r.png" alt=""> -->
* <p>
* <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/mergeMap.r.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code flatMap} does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down Expand Up @@ -8050,6 +8050,8 @@ public final <U, R> Observable<R> flatMap(Function<? super T, ? extends Observab
/**
* Maps each element of the upstream Observable into CompletableSources, subscribes to them and
* waits until the upstream and all CompletableSources complete.
* <p>
* <img width="640" height="424" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapCompletable.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code flatMapCompletable} does not operate by default on a particular {@link Scheduler}.</dd>
Expand All @@ -8066,6 +8068,8 @@ public final Completable flatMapCompletable(Function<? super T, ? extends Comple
/**
* Maps each element of the upstream Observable into CompletableSources, subscribes to them and
* waits until the upstream and all CompletableSources complete, optionally delaying all errors.
* <p>
* <img width="640" height="361" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapCompletableDelayError.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code flatMapCompletable} does not operate by default on a particular {@link Scheduler}.</dd>
Expand All @@ -8086,7 +8090,7 @@ public final Completable flatMapCompletable(Function<? super T, ? extends Comple
* Returns an Observable that merges 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="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapIterable.o.png" alt="">
* <img width="640" height="343" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapIterable.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code flatMapIterable} does not operate by default on a particular {@link Scheduler}.</dd>
Expand All @@ -8112,7 +8116,7 @@ public final <U> Observable<U> flatMapIterable(final Function<? super T, ? exten
* Returns an Observable that emits the results of applying a function to the pair of values from the source
* ObservableSource and an Iterable corresponding to that item that is generated by a selector.
* <p>
* <img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapIterable.o.r.png" alt="">
* <img width="640" height="410" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/flatMapIterable.o.r.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code flatMapIterable} does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down Expand Up @@ -8228,6 +8232,8 @@ public final <R> Observable<R> flatMapSingle(Function<? super T, ? extends Singl
/**
* Subscribes to the {@link ObservableSource} and receives notifications for each element.
* <p>
* <img width="640" height="264" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/forEach.o.png" alt="">
* <p>
* Alias to {@link #subscribe(Consumer)}
* <dl>
* <dt><b>Scheduler:</b></dt>
Expand All @@ -8252,6 +8258,8 @@ public final Disposable forEach(Consumer<? super T> onNext) {
* Subscribes to the {@link ObservableSource} and receives notifications for each element until the
* onNext Predicate returns false.
* <p>
* <img width="640" height="272" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/forEachWhile.o.png" alt="">
* <p>
* If the Observable emits an error, it is wrapped into an
* {@link io.reactivex.exceptions.OnErrorNotImplementedException OnErrorNotImplementedException}
* and routed to the RxJavaPlugins.onError handler.
Expand Down Expand Up @@ -8584,6 +8592,8 @@ public final <TRight, TLeftEnd, TRightEnd, R> Observable<R> groupJoin(
* <p>Allows hiding extra features such as {@link io.reactivex.subjects.Subject}'s
* {@link Observer} methods or preventing certain identity-based
* optimizations (fusion).
* <p>
* <img width="640" height="283" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/hide.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code hide} does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down