Skip to content

Commit 6e7de23

Browse files
committed
3.x: Javadocs: indicate takeUntil stops on completion of other
1 parent 54114b9 commit 6e7de23

File tree

4 files changed

+8
-8
lines changed

4 files changed

+8
-8
lines changed

src/main/java/io/reactivex/rxjava3/core/Flowable.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16972,9 +16972,9 @@ public final Flowable<T> takeUntil(@NonNull Predicate<? super T> stopPredicate)
1697216972

1697316973
/**
1697416974
* Returns a {@code Flowable} that emits the items emitted by the current {@code Flowable} until a second {@link Publisher}
16975-
* emits an item.
16975+
* emits an item or completes.
1697616976
* <p>
16977-
* <img width="640" height="380" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/takeUntil.v3.png" alt="">
16977+
* <img width="640" height="188" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Flowable.takeUntil.p.png" alt="">
1697816978
* <dl>
1697916979
* <dt><b>Backpressure:</b></dt>
1698016980
* <dd>The operator doesn't interfere with backpressure which is determined by the current {@code Flowable}'s backpressure
@@ -16984,7 +16984,7 @@ public final Flowable<T> takeUntil(@NonNull Predicate<? super T> stopPredicate)
1698416984
* </dl>
1698516985
*
1698616986
* @param other
16987-
* the {@code Publisher} whose first emitted item will cause {@code takeUntil} to stop emitting items
16987+
* the {@code Publisher} whose first emitted item or completion will cause {@code takeUntil} to stop emitting items
1698816988
* from the current {@code Flowable}
1698916989
* @param <U>
1699016990
* the type of items emitted by {@code other}

src/main/java/io/reactivex/rxjava3/core/Observable.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14028,16 +14028,16 @@ public final Observable<T> takeLast(long time, @NonNull TimeUnit unit, @NonNull
1402814028

1402914029
/**
1403014030
* Returns an {@code Observable} that emits the items emitted by the current {@code Observable} until a second {@link ObservableSource}
14031-
* emits an item.
14031+
* emits an item or completes.
1403214032
* <p>
14033-
* <img width="640" height="380" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/takeUntil.v3.png" alt="">
14033+
* <img width="640" height="213" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Observable.takeUntil.o.png" alt="">
1403414034
* <dl>
1403514035
* <dt><b>Scheduler:</b></dt>
1403614036
* <dd>{@code takeUntil} does not operate by default on a particular {@link Scheduler}.</dd>
1403714037
* </dl>
1403814038
*
1403914039
* @param other
14040-
* the {@code ObservableSource} whose first emitted item will cause {@code takeUntil} to stop emitting items
14040+
* the {@code ObservableSource} whose first emitted item or completion will cause {@code takeUntil} to stop emitting items
1404114041
* from the current {@code Observable}
1404214042
* @param <U>
1404314043
* the type of items emitted by {@code other}

src/main/java/io/reactivex/rxjava3/operators/QueueDisposable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818

1919
/**
2020
* An interface extending {@link SimpleQueue} and {@link Disposable} and allows negotiating
21-
* the fusion mode between subsequent operators of the {@link Observable} base reactive type.
21+
* the fusion mode between subsequent operators of the {@link io.reactivex.rxjava3.core.Observable Observable} base reactive type.
2222
* <p>
2323
* The negotiation happens in subscription time when the upstream
2424
* calls the {@code onSubscribe} with an instance of this interface. The

src/main/java/io/reactivex/rxjava3/operators/QueueSubscription.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919

2020
/**
2121
* An interface extending {@link SimpleQueue} and {@link Subscription} and allows negotiating
22-
* the fusion mode between subsequent operators of the {@link Flowable} base reactive type.
22+
* the fusion mode between subsequent operators of the {@link io.reactivex.rxjava3.core.Flowable Flowable} base reactive type.
2323
* <p>
2424
* The negotiation happens in subscription time when the upstream
2525
* calls the {@code onSubscribe} with an instance of this interface. The

0 commit comments

Comments
 (0)