diff --git a/src/main/java/io/reactivex/Flowable.java b/src/main/java/io/reactivex/Flowable.java index d15f735a44..f4519888d0 100644 --- a/src/main/java/io/reactivex/Flowable.java +++ b/src/main/java/io/reactivex/Flowable.java @@ -13392,6 +13392,9 @@ public final Flowable take(long count) { * Returns a Flowable that emits those items emitted by source Publisher before a specified time runs * out. *

+ * If time runs out before the {@code Flowable} completes normally, the {@code onComplete} event will be + * signaled on the default {@code computation} {@link Scheduler}. + *

* *

*
Backpressure:
@@ -13419,6 +13422,9 @@ public final Flowable take(long time, TimeUnit unit) { * Returns a Flowable that emits those items emitted by source Publisher before a specified time (on a * specified Scheduler) runs out. *

+ * If time runs out before the {@code Flowable} completes normally, the {@code onComplete} event will be + * signaled on the provided {@link Scheduler}. + *

* *

*
Backpressure:
diff --git a/src/main/java/io/reactivex/Observable.java b/src/main/java/io/reactivex/Observable.java index ba82c99c7a..abdcea3b4c 100644 --- a/src/main/java/io/reactivex/Observable.java +++ b/src/main/java/io/reactivex/Observable.java @@ -11286,6 +11286,9 @@ public final Observable take(long count) { * Returns an Observable that emits those items emitted by source ObservableSource before a specified time runs * out. *

+ * If time runs out before the {@code Observable} completes normally, the {@code onComplete} event will be + * signaled on the default {@code computation} {@link Scheduler}. + *

* *

*
Scheduler:
@@ -11309,6 +11312,9 @@ public final Observable take(long time, TimeUnit unit) { * Returns an Observable that emits those items emitted by source ObservableSource before a specified time (on a * specified Scheduler) runs out. *

+ * If time runs out before the {@code Observable} completes normally, the {@code onComplete} event will be + * signaled on the provided {@link Scheduler}. + *

* *

*
Scheduler: