Skip to content

Commit c358741

Browse files
authored
2.x: Add C.delaySubscription marble, fix some javadoc (#6257)
1 parent 378cbf9 commit c358741

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1393,6 +1393,7 @@ public final Completable delay(final long delay, final TimeUnit unit, final Sche
13931393
/**
13941394
* Returns a Completable that delays the subscription to the source CompletableSource by a given amount of time.
13951395
* <p>
1396+
* <img width="640" height="475" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.delaySubscription.t.png" alt="">
13961397
* <dl>
13971398
* <dt><b>Scheduler:</b></dt>
13981399
* <dd>This version of {@code delaySubscription} operates by default on the {@code computation} {@link Scheduler}.</dd>
@@ -1415,6 +1416,7 @@ public final Completable delaySubscription(long delay, TimeUnit unit) {
14151416
* Returns a Completable that delays the subscription to the source CompletableSource by a given amount of time,
14161417
* both waiting and subscribing on a given Scheduler.
14171418
* <p>
1419+
* <img width="640" height="420" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.delaySubscription.ts.png" alt="">
14181420
* <dl>
14191421
* <dt><b>Scheduler:</b></dt>
14201422
* <dd>You specify which {@link Scheduler} this operator will use.</dd>

src/main/java/io/reactivex/internal/fuseable/ConditionalSubscriber.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
import io.reactivex.FlowableSubscriber;
1717

1818
/**
19-
* A Subscriber with an additional onNextIf(T) method that
19+
* A Subscriber with an additional {@link #tryOnNext(Object)} method that
2020
* tells the caller the specified value has been accepted or
2121
* not.
2222
*
@@ -30,6 +30,7 @@ public interface ConditionalSubscriber<T> extends FlowableSubscriber<T> {
3030
* Conditionally takes the value.
3131
* @param t the value to deliver
3232
* @return true if the value has been accepted, false if the value has been rejected
33+
* and the next value can be sent immediately
3334
*/
3435
boolean tryOnNext(T t);
3536
}

0 commit comments

Comments
 (0)