@@ -1596,7 +1596,7 @@ public final Completable doOnEvent(@NonNull Consumer<@Nullable ? super Throwable
1596
1596
* </dl>
1597
1597
* @param onSubscribe the consumer called when a {@link CompletableObserver} subscribes.
1598
1598
* @param onError the consumer called when this emits an {@code onError} event
1599
- * @param onComplete the runnable called just before when the upstream {@code Completable} completes normally
1599
+ * @param onComplete the runnable called just before when the current {@code Completable} completes normally
1600
1600
* @param onAfterTerminate the runnable called after this {@code Completable} completes normally
1601
1601
* @param onDispose the {@link Runnable} called when the downstream disposes the subscription
1602
1602
* @return the new {@code Completable} instance
@@ -1834,7 +1834,7 @@ public final Completable doFinally(@NonNull Action onFinally) {
1834
1834
* <p>
1835
1835
* Note also that it is not possible to stop the subscription phase in {@code lift()} as the {@code apply()} method
1836
1836
* requires a non-{@code null} {@code CompletableObserver} instance to be returned, which is then unconditionally subscribed to
1837
- * the upstream {@code Completable}. For example, if the operator decided there is no reason to subscribe to the
1837
+ * the current {@code Completable}. For example, if the operator decided there is no reason to subscribe to the
1838
1838
* upstream source because of some optimization possibility or a failure to prepare the operator, it still has to
1839
1839
* return a {@code CompletableObserver} that should immediately dispose the upstream's {@link Disposable} in its
1840
1840
* {@code onSubscribe} method. Again, using a {@code CompletableTransformer} and extending the {@code Completable} is
@@ -2692,7 +2692,7 @@ public final <T> Flowable<T> toFlowable() {
2692
2692
*
2693
2693
* @param <T> the value type
2694
2694
* @return a {@code Maybe} that only calls {@code onComplete} or {@code onError}, based on which one is
2695
- * called by the source {@code Completable}.
2695
+ * called by the current {@code Completable}.
2696
2696
*/
2697
2697
@ CheckReturnValue
2698
2698
@ SuppressWarnings ("unchecked" )
0 commit comments