Skip to content

Commit c0f17ce

Browse files
UMFsimkeakarnokd
authored andcommitted
Add marbles for Single.timer, Single.defer and Single.toXXX operators (#6095)
* Add marbles for Single.timer, Single.defer and Single.toXXX operators * Correct image height for marbles
1 parent a008e03 commit c0f17ce

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

src/main/java/io/reactivex/Single.java

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -493,6 +493,8 @@ public static <T> Single<T> create(SingleOnSubscribe<T> source) {
493493
/**
494494
* Calls a {@link Callable} for each individual {@link SingleObserver} to return the actual {@link SingleSource} to
495495
* be subscribed to.
496+
* <p>
497+
* <img width="640" height="515" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.defer.png" alt="">
496498
* <dl>
497499
* <dt><b>Scheduler:</b></dt>
498500
* <dd>{@code defer} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -1243,6 +1245,8 @@ public static <T> Single<T> never() {
12431245

12441246
/**
12451247
* Signals success with 0L value after the given delay for each SingleObserver.
1248+
* <p>
1249+
* <img width="640" height="292" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.timer.png" alt="">
12461250
* <dl>
12471251
* <dt><b>Scheduler:</b></dt>
12481252
* <dd>{@code timer} operates by default on the {@code computation} {@link Scheduler}.</dd>
@@ -1260,6 +1264,8 @@ public static Single<Long> timer(long delay, TimeUnit unit) {
12601264

12611265
/**
12621266
* Signals success with 0L value after the given delay for each SingleObserver.
1267+
* <p>
1268+
* <img width="640" height="292" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.timer.s.png" alt="">
12631269
* <dl>
12641270
* <dt><b>Scheduler:</b></dt>
12651271
* <dd>you specify the {@link Scheduler} to signal on.</dd>
@@ -3705,7 +3711,7 @@ public final Completable ignoreElement() {
37053711
/**
37063712
* Converts this Single into a {@link Flowable}.
37073713
* <p>
3708-
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.toObservable.png" alt="">
3714+
* <img width="640" height="462" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.toFlowable.png" alt="">
37093715
* <dl>
37103716
* <dt><b>Backpressure:</b></dt>
37113717
* <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>
@@ -3729,7 +3735,7 @@ public final Flowable<T> toFlowable() {
37293735
/**
37303736
* Returns a {@link Future} representing the single value emitted by this {@code Single}.
37313737
* <p>
3732-
* <img width="640" height="395" src="https://github.com/ReactiveX/RxJava/wiki/images/rx-operators/B.toFuture.png" alt="">
3738+
* <img width="640" height="467" src="https://github.com/ReactiveX/RxJava/wiki/images/rx-operators/Single.toFuture.png" alt="">
37333739
* <dl>
37343740
* <dt><b>Scheduler:</b></dt>
37353741
* <dd>{@code toFuture} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -3747,7 +3753,7 @@ public final Future<T> toFuture() {
37473753
/**
37483754
* Converts this Single into a {@link Maybe}.
37493755
* <p>
3750-
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.toObservable.png" alt="">
3756+
* <img width="640" height="463" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.toMaybe.png" alt="">
37513757
* <dl>
37523758
* <dt><b>Scheduler:</b></dt>
37533759
* <dd>{@code toMaybe} does not operate by default on a particular {@link Scheduler}.</dd>

0 commit comments

Comments
 (0)