Skip to content

Commit a80b657

Browse files
authored
2.x: Several more Completable marbles (7/19b) (#6098)
1 parent 8b97408 commit a80b657

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

src/main/java/io/reactivex/Completable.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2230,6 +2230,8 @@ public final Disposable subscribe(final Action onComplete) {
22302230
/**
22312231
* Returns a Completable which subscribes the child subscriber on the specified scheduler, making
22322232
* 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="">
22332235
* <dl>
22342236
* <dt><b>Scheduler:</b></dt>
22352237
* <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) {
24052407
/**
24062408
* Returns a Flowable which when subscribed to subscribes to this Completable and
24072409
* 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="">
24082412
* <dl>
24092413
* <dt><b>Backpressure:</b></dt>
24102414
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>
@@ -2427,6 +2431,8 @@ public final <T> Flowable<T> toFlowable() {
24272431

24282432
/**
24292433
* 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="">
24302436
* <dl>
24312437
* <dt><b>Scheduler:</b></dt>
24322438
* <dd>{@code toMaybe} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -2471,6 +2477,8 @@ public final <T> Observable<T> toObservable() {
24712477
/**
24722478
* Converts this Completable into a Single which when this Completable completes normally,
24732479
* 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="">
24742482
* <dl>
24752483
* <dt><b>Scheduler:</b></dt>
24762484
* <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
24902498
/**
24912499
* Converts this Completable into a Single which when this Completable completes normally,
24922500
* 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="">
24932503
* <dl>
24942504
* <dt><b>Scheduler:</b></dt>
24952505
* <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) {
25092519
/**
25102520
* Returns a Completable which makes sure when a subscriber cancels the subscription, the
25112521
* 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="">
25122524
* <dl>
25132525
* <dt><b>Scheduler:</b></dt>
25142526
* <dd>{@code unsubscribeOn} calls dispose() of the upstream on the {@link Scheduler} you specify.</dd>

0 commit comments

Comments
 (0)