diff --git a/src/main/java/io/reactivex/Completable.java b/src/main/java/io/reactivex/Completable.java index c1d6b2fb07..06a9cd79da 100644 --- a/src/main/java/io/reactivex/Completable.java +++ b/src/main/java/io/reactivex/Completable.java @@ -1283,6 +1283,8 @@ public final Completable compose(CompletableTransformer transformer) { /** * Concatenates this Completable with another Completable. + *

+ * *

*
Scheduler:
*
{@code concatWith} does not operate by default on a particular {@link Scheduler}.
@@ -1304,6 +1306,8 @@ public final Completable concatWith(CompletableSource other) { /** * Returns a Completable which delays the emission of the completion event by the given time. + *

+ * *

*
Scheduler:
*
{@code delay} does operate by default on the {@code computation} {@link Scheduler}.
@@ -1322,6 +1326,8 @@ public final Completable delay(long delay, TimeUnit unit) { /** * Returns a Completable which delays the emission of the completion event by the given time while * running on the specified scheduler. + *

+ * *

*
Scheduler:
*
{@code delay} operates on the {@link Scheduler} you specify.
@@ -1341,6 +1347,8 @@ public final Completable delay(long delay, TimeUnit unit, Scheduler scheduler) { /** * Returns a Completable which delays the emission of the completion event, and optionally the error as well, by the given time while * running on the specified scheduler. + *

+ * *

*
Scheduler:
*
{@code delay} operates on the {@link Scheduler} you specify.
@@ -1362,6 +1370,8 @@ public final Completable delay(final long delay, final TimeUnit unit, final Sche /** * Returns a Completable which calls the given onComplete callback if this Completable completes. + *

+ * *

*
Scheduler:
*
{@code doOnComplete} does not operate by default on a particular {@link Scheduler}.
@@ -1382,6 +1392,8 @@ public final Completable doOnComplete(Action onComplete) { /** * Calls the shared {@code Action} if a CompletableObserver subscribed to the current * Completable disposes the common Disposable it received via onSubscribe. + *

+ * *

*
Scheduler:
*
{@code doOnDispose} does not operate by default on a particular {@link Scheduler}.
@@ -1400,6 +1412,8 @@ public final Completable doOnDispose(Action onDispose) { /** * Returns a Completable which calls the given onError callback if this Completable emits an error. + *

+ * *

*
Scheduler:
*
{@code doOnError} does not operate by default on a particular {@link Scheduler}.
@@ -1420,6 +1434,8 @@ public final Completable doOnError(Consumer onError) { /** * Returns a Completable which calls the given onEvent callback with the (throwable) for an onError * or (null) for an onComplete signal from this Completable before delivering said signal to the downstream. + *

+ * *

*
Scheduler:
*
{@code doOnEvent} does not operate by default on a particular {@link Scheduler}.
@@ -1470,6 +1486,8 @@ private Completable doOnLifecycle( /** * Returns a Completable instance that calls the given onSubscribe callback with the disposable * that child subscribers receive on subscription. + *

+ * *

*
Scheduler:
*
{@code doOnSubscribe} does not operate by default on a particular {@link Scheduler}.
@@ -1489,6 +1507,8 @@ public final Completable doOnSubscribe(Consumer onSubscribe) /** * Returns a Completable instance that calls the given onTerminate callback just before this Completable * completes normally or with an exception. + *

+ * *

*
Scheduler:
*
{@code doOnTerminate} does not operate by default on a particular {@link Scheduler}.
@@ -1508,6 +1528,8 @@ public final Completable doOnTerminate(final Action onTerminate) { /** * Returns a Completable instance that calls the given onTerminate callback after this Completable * completes normally or with an exception. + *

+ * *

*
Scheduler:
*
{@code doAfterTerminate} does not operate by default on a particular {@link Scheduler}.
@@ -1530,9 +1552,13 @@ public final Completable doAfterTerminate(final Action onAfterTerminate) { /** * Calls the specified action after this Completable signals onError or onComplete or gets disposed by * the downstream. - *

In case of a race between a terminal event and a dispose call, the provided {@code onFinally} action + *

+ * + *

+ * In case of a race between a terminal event and a dispose call, the provided {@code onFinally} action * is executed once per subscription. - *

Note that the {@code onFinally} action is shared between subscriptions and as such + *

+ * Note that the {@code onFinally} action is shared between subscriptions and as such * should be thread-safe. *

*
Scheduler:
@@ -1688,6 +1714,8 @@ public final Completable lift(final CompletableOperator onLift) { /** * Returns a Completable which subscribes to this and the other Completable and completes * when both of them complete or one emits an error. + *

+ * *

*
Scheduler:
*
{@code mergeWith} does not operate by default on a particular {@link Scheduler}.
@@ -1705,6 +1733,8 @@ public final Completable mergeWith(CompletableSource other) { /** * Returns a Completable which emits the terminal events from the thread of the specified scheduler. + *

+ * *

*
Scheduler:
*
{@code observeOn} operates on a {@link Scheduler} you specify.
@@ -1723,6 +1753,8 @@ public final Completable observeOn(final Scheduler scheduler) { /** * Returns a Completable instance that if this Completable emits an error, it will emit an onComplete * and swallow the throwable. + *

+ * *

*
Scheduler:
*
{@code onErrorComplete} does not operate by default on a particular {@link Scheduler}.
@@ -1738,6 +1770,8 @@ public final Completable onErrorComplete() { /** * Returns a Completable instance that if this Completable emits an error and the predicate returns * true, it will emit an onComplete and swallow the throwable. + *

+ * *

*
Scheduler:
*
{@code onErrorComplete} does not operate by default on a particular {@link Scheduler}.
@@ -1758,6 +1792,8 @@ public final Completable onErrorComplete(final Predicate pred * Returns a Completable instance that when encounters an error from this Completable, calls the * specified mapper function that returns another Completable instance for it and resumes the * execution with it. + *

+ * *

*
Scheduler:
*
{@code onErrorResumeNext} does not operate by default on a particular {@link Scheduler}.
@@ -1776,6 +1812,8 @@ public final Completable onErrorResumeNext(final Function + * *
*
Scheduler:
*
{@code onTerminateDetach} does not operate by default on a particular {@link Scheduler}.
@@ -2050,8 +2088,10 @@ public final Flowable startWith(Publisher other) { /** * Hides the identity of this Completable and its Disposable. - *

Allows preventing certain identity-based - * optimizations (fusion). + *

+ * + *

+ * Allows preventing certain identity-based optimizations (fusion). *

*
Scheduler:
*
{@code hide} does not operate by default on a particular {@link Scheduler}.