Skip to content

Commit 048175a

Browse files
sadeghakarnokd
authored andcommitted
1.x: Add a sentence to documentation of take() operator (#5719)
* Add a sentence to documentation of take() operator * Rephrase java doc for take() method
1 parent 5b2394c commit 048175a

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/main/java/rx/Observable.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10536,6 +10536,9 @@ public final Observable<T> take(final int count) {
1053610536
* Returns an Observable that emits those items emitted by source Observable before a specified time runs
1053710537
* out.
1053810538
* <p>
10539+
* If time runs out before the {@code Observable} completes normally, the {@code onComplete} event will be
10540+
* signaled on the default {@code computation} {@link Scheduler}.
10541+
* <p>
1053910542
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/take.t.png" alt="">
1054010543
* <dl>
1054110544
* <dt><b>Backpressure:</b></dt>
@@ -10560,6 +10563,9 @@ public final Observable<T> take(long time, TimeUnit unit) {
1056010563
* Returns an Observable that emits those items emitted by source Observable before a specified time (on a
1056110564
* specified Scheduler) runs out.
1056210565
* <p>
10566+
* If time runs out before the {@code Observable} completes normally, the {@code onComplete} event will be
10567+
* signaled on the provided {@link Scheduler}.
10568+
* <p>
1056310569
* <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/take.ts.png" alt="">
1056410570
* <dl>
1056510571
* <dt><b>Backpressure:</b></dt>

0 commit comments

Comments
 (0)