-
Notifications
You must be signed in to change notification settings - Fork 7.6k
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.
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
Add "error handling" java docs section to from callable & co #6193
The head ref may contain hidden characters: "Add-\"Error-handling\"-JavaDocs-section-to-fromCallable-&-co"
Changes from 2 commits
ea52ed8
ee99e0b
58f3909
5c1eeb9
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -396,6 +396,13 @@ public static Completable error(final Throwable error) { | |
* <dl> | ||
* <dt><b>Scheduler:</b></dt> | ||
* <dd>{@code fromAction} does not operate by default on a particular {@link Scheduler}.</dd> | ||
* <dt><b>Error handling:</b></dt> | ||
* <dd> If the {@link Action} throws an exception, the respective {@link Throwable} is | ||
* delivered to the downstream via {@link CompletableObserver#onError(Throwable)}, | ||
* except when the downstream has canceled or disposed this {@code Completable} source. | ||
* In this latter case, the {@code Throwable} is delivered to the global error handler via | ||
* {@link RxJavaPlugins#onError(Throwable)} as an {@link io.reactivex.exceptions.UndeliverableException UndeliverableException}. | ||
* </dd> | ||
* </dl> | ||
* @param run the runnable to run for each subscriber | ||
* @return the new Completable instance | ||
|
@@ -416,6 +423,13 @@ public static Completable fromAction(final Action run) { | |
* <dl> | ||
* <dt><b>Scheduler:</b></dt> | ||
* <dd>{@code fromCallable} does not operate by default on a particular {@link Scheduler}.</dd> | ||
* <dt><b>Error handling:</b></dt> | ||
* <dd> If the {@link Callable} throws an exception, the respective {@link Throwable} is | ||
* delivered to the downstream via {@link CompletableObserver#onError(Throwable)}, | ||
* except when the downstream has canceled or disposed this {@code Completable} source. | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. "downstream has disposed this" |
||
* In this latter case, the {@code Throwable} is delivered to the global error handler via | ||
* {@link RxJavaPlugins#onError(Throwable)} as an {@link io.reactivex.exceptions.UndeliverableException UndeliverableException}. | ||
* </dd> | ||
* </dl> | ||
* @param callable the callable instance to execute for each subscriber | ||
* @return the new Completable instance | ||
|
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -657,6 +657,13 @@ public static <T> Maybe<T> error(Callable<? extends Throwable> supplier) { | |
* <dl> | ||
* <dt><b>Scheduler:</b></dt> | ||
* <dd>{@code fromAction} does not operate by default on a particular {@link Scheduler}.</dd> | ||
* <dt><b>Error handling:</b></dt> | ||
* <dd> If the {@link Action} throws an exception, the respective {@link Throwable} is | ||
* delivered to the downstream via {@link MaybeObserver#onError(Throwable)}, | ||
* except when the downstream has canceled or disposed this {@code Maybe} source. | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. "downstream has disposed this" |
||
* In this latter case, the {@code Throwable} is delivered to the global error handler via | ||
* {@link RxJavaPlugins#onError(Throwable)} as an {@link io.reactivex.exceptions.UndeliverableException UndeliverableException}. | ||
* </dd> | ||
* </dl> | ||
* @param <T> the target type | ||
* @param run the runnable to run for each subscriber | ||
|
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -1757,8 +1757,14 @@ public static <T> Observable<T> fromArray(T... items) { | |
* <dl> | ||
* <dt><b>Scheduler:</b></dt> | ||
* <dd>{@code fromCallable} does not operate by default on a particular {@link Scheduler}.</dd> | ||
* <dt><b>Error handling:</b></dt> | ||
* <dd> If the {@link Callable} throws an exception, the respective {@link Throwable} is | ||
* delivered to the downstream via {@link Observer#onError(Throwable)}, | ||
* except when the downstream has canceled or disposed this {@code Observable} source. | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. "downstream has disposed this" |
||
* In this latter case, the {@code Throwable} is delivered to the global error handler via | ||
* {@link RxJavaPlugins#onError(Throwable)} as an {@link io.reactivex.exceptions.UndeliverableException UndeliverableException}. | ||
* </dd> | ||
* </dl> | ||
* | ||
* @param supplier | ||
* a function, the execution of which should be deferred; {@code fromCallable} will invoke this | ||
* function only when an observer subscribes to the ObservableSource that {@code fromCallable} returns | ||
|
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -583,6 +583,13 @@ public static <T> Single<T> error(final Throwable exception) { | |
* <dl> | ||
* <dt><b>Scheduler:</b></dt> | ||
* <dd>{@code fromCallable} does not operate by default on a particular {@link Scheduler}.</dd> | ||
* <dt><b>Error handling:</b></dt> | ||
* <dd> If the {@link Callable} throws an exception, the respective {@link Throwable} is | ||
* delivered to the downstream via {@link SingleObserver#onError(Throwable)}, | ||
* except when the downstream has canceled or disposed this {@code Single} source. | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. "downstream has disposed this" |
||
* In this latter case, the {@code Throwable} is delivered to the global error handler via | ||
* {@link RxJavaPlugins#onError(Throwable)} as an {@link io.reactivex.exceptions.UndeliverableException UndeliverableException}. | ||
* </dd> | ||
* </dl> | ||
* | ||
* @param callable | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
"downstream has disposed this" as only
Flowable
s havecancel
.