Commit a80b657
authored
2.x: Several more Completable marbles (7/19b) (ReactiveX#6098)
1 parent 8b97408 commit a80b657
1 file changed
Lines changed: 12 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -2230,6 +2230,8 @@ public final Disposable subscribe(final Action onComplete) { | |||
| 2230 | 2230 | /** | |
| 2231 | 2231 | * Returns a Completable which subscribes the child subscriber on the specified scheduler, making | |
| 2232 | 2232 | * sure the subscription side-effects happen on that specific thread of the scheduler. | |
| 2233 | + * <p> | ||
| 2234 | + * <img width="640" height="686" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.subscribeOn.png" alt=""> | ||
| 2233 | 2235 | * <dl> | |
| 2234 | 2236 | * <dt><b>Scheduler:</b></dt> | |
| 2235 | 2237 | * <dd>{@code subscribeOn} operates on a {@link Scheduler} you specify.</dd> | |
@@ -2405,6 +2407,8 @@ public final <U> U to(Function<? super Completable, U> converter) { | |||
| 2405 | 2407 | /** | |
| 2406 | 2408 | * Returns a Flowable which when subscribed to subscribes to this Completable and | |
| 2407 | 2409 | * relays the terminal events to the subscriber. | |
| 2410 | + * <p> | ||
| 2411 | + * <img width="640" height="585" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.toFlowable.png" alt=""> | ||
| 2408 | 2412 | * <dl> | |
| 2409 | 2413 | * <dt><b>Backpressure:</b></dt> | |
| 2410 | 2414 | * <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd> | |
@@ -2427,6 +2431,8 @@ public final <T> Flowable<T> toFlowable() { | |||
| 2427 | 2431 | ||
| 2428 | 2432 | /** | |
| 2429 | 2433 | * Converts this Completable into a {@link Maybe}. | |
| 2434 | + * <p> | ||
| 2435 | + * <img width="640" height="585" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.toMaybe.png" alt=""> | ||
| 2430 | 2436 | * <dl> | |
| 2431 | 2437 | * <dt><b>Scheduler:</b></dt> | |
| 2432 | 2438 | * <dd>{@code toMaybe} does not operate by default on a particular {@link Scheduler}.</dd> | |
@@ -2471,6 +2477,8 @@ public final <T> Observable<T> toObservable() { | |||
| 2471 | 2477 | /** | |
| 2472 | 2478 | * Converts this Completable into a Single which when this Completable completes normally, | |
| 2473 | 2479 | * calls the given supplier and emits its returned value through onSuccess. | |
| 2480 | + * <p> | ||
| 2481 | + * <img width="640" height="583" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.toSingle.png" alt=""> | ||
| 2474 | 2482 | * <dl> | |
| 2475 | 2483 | * <dt><b>Scheduler:</b></dt> | |
| 2476 | 2484 | * <dd>{@code toSingle} does not operate by default on a particular {@link Scheduler}.</dd> | |
@@ -2490,6 +2498,8 @@ public final <T> Single<T> toSingle(final Callable<? extends T> completionValueS | |||
| 2490 | 2498 | /** | |
| 2491 | 2499 | * Converts this Completable into a Single which when this Completable completes normally, | |
| 2492 | 2500 | * emits the given value through onSuccess. | |
| 2501 | + * <p> | ||
| 2502 | + * <img width="640" height="583" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.toSingleDefault.png" alt=""> | ||
| 2493 | 2503 | * <dl> | |
| 2494 | 2504 | * <dt><b>Scheduler:</b></dt> | |
| 2495 | 2505 | * <dd>{@code toSingleDefault} does not operate by default on a particular {@link Scheduler}.</dd> | |
@@ -2509,6 +2519,8 @@ public final <T> Single<T> toSingleDefault(final T completionValue) { | |||
| 2509 | 2519 | /** | |
| 2510 | 2520 | * Returns a Completable which makes sure when a subscriber cancels the subscription, the | |
| 2511 | 2521 | * dispose is called on the specified scheduler. | |
| 2522 | + * <p> | ||
| 2523 | + * <img width="640" height="716" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.unsubscribeOn.png" alt=""> | ||
| 2512 | 2524 | * <dl> | |
| 2513 | 2525 | * <dt><b>Scheduler:</b></dt> | |
| 2514 | 2526 | * <dd>{@code unsubscribeOn} calls dispose() of the upstream on the {@link Scheduler} you specify.</dd> | |
0 commit comments