diff --git a/src/main/java/io/reactivex/Completable.java b/src/main/java/io/reactivex/Completable.java index 42ae598e35..d00cd9b451 100644 --- a/src/main/java/io/reactivex/Completable.java +++ b/src/main/java/io/reactivex/Completable.java @@ -264,6 +264,8 @@ public static Completable concat(Publisher sources, /** * Provides an API (via a cold Completable) that bridges the reactive world with the callback-style world. *

+ * + *

* Example: * 


      * Completable.create(emitter -> {
@@ -305,6 +307,8 @@ public static Completable create(CompletableOnSubscribe source) {
      * Constructs a Completable instance by wrapping the given source callback
      * without any safeguards; you should manage the lifecycle and response
      * to downstream cancellation/dispose.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -1585,6 +1589,8 @@ public final Completable doFinally(Action onFinally) {
      * and providing a new {@code CompletableObserver}, containing the custom operator's intended business logic, that will be
      * used in the subscription process going further upstream.
      * 

+     * 
+     * 

      * Generally, such a new {@code CompletableObserver} will wrap the downstream's {@code CompletableObserver} and forwards the
      * {@code onError} and {@code onComplete} events from the upstream directly or according to the
      * emission pattern the custom operator's business logic requires. In addition, such operator can intercept the
@@ -1831,6 +1837,8 @@ public final Completable onTerminateDetach() {
 
     /**
      * Returns a Completable that repeatedly subscribes to this Completable until cancelled.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -1845,6 +1853,8 @@ public final Completable repeat() {
 
     /**
      * Returns a Completable that subscribes repeatedly at most the given times to this Completable.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -1862,6 +1872,8 @@ public final Completable repeat(long times) {
     /**
      * Returns a Completable that repeatedly subscribes to this Completable so long as the given
      * stop supplier returns false.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -1879,6 +1891,8 @@ public final Completable repeatUntil(BooleanSupplier stop) {
     /**
      * Returns a Completable instance that repeats when the Publisher returned by the handler
      * emits an item or completes when this Publisher emits a completed event.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -1897,6 +1911,8 @@ public final Completable repeatWhen(Function, ? extends
 
     /**
      * Returns a Completable that retries this Completable as long as it emits an onError event.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -1912,6 +1928,8 @@ public final Completable retry() {
     /**
      * Returns a Completable that retries this Completable in case of an error as long as the predicate
      * returns true.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -1929,6 +1947,8 @@ public final Completable retry(BiPredicate p
     /**
      * Returns a Completable that when this Completable emits an error, retries at most the given
      * number of times before giving up and emitting the last error.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -1946,6 +1966,8 @@ public final Completable retry(long times) {
     /**
      * Returns a Completable that when this Completable emits an error, retries at most times
      * or until the predicate returns false, whichever happens first and emitting the last error.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -1968,6 +1990,8 @@ public final Completable retry(long times, Predicate predicat
     /**
      * Returns a Completable that when this Completable emits an error, calls the given predicate with
      * the latest exception to decide whether to resubscribe to this or not.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -1988,6 +2012,8 @@ public final Completable retry(Predicate predicate) {
      * that error through a Flowable and the Publisher should signal a value indicating a retry in response
      * or a terminal event indicating a termination.
      * 

+     * 
+     * 

      * Note that the inner {@code Publisher} returned by the handler function should signal
      * either {@code onNext}, {@code onError} or {@code onComplete} in response to the received
      * {@code Throwable} to indicate the operator should retry or terminate. If the upstream to
@@ -2030,6 +2056,8 @@ public final Completable retryWhen(Function, ? exten
     /**
      * Returns a Completable which first runs the other Completable
      * then this completable if the other completed normally.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -2048,6 +2076,8 @@ public final Completable startWith(CompletableSource other) {
     /**
      * Returns an Observable which first delivers the events
      * of the other Observable then runs this CompletableConsumable.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -2066,6 +2096,8 @@ public final  Observable startWith(Observable other) {
     /**
      * Returns a Flowable which first delivers the events
      * of the other Publisher then runs this Completable.
+     * 

+     * 
      * 

      *  
Backpressure:

      *  
The returned {@code Flowable} honors the backpressure of the downstream consumer
@@ -2109,6 +2141,8 @@ public final Completable hide() {
     /**
      * Subscribes to this CompletableConsumable and returns a Disposable which can be used to cancel
      * the subscription.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -2153,6 +2187,8 @@ public final void subscribe(CompletableObserver s) {
     /**
      * Subscribes a given CompletableObserver (subclass) to this Completable and returns the given
      * CompletableObserver as is.
+     * 

+     * 
      * 
Usage example:
      * 

      * Completable source = Completable.complete().delay(1, TimeUnit.SECONDS);
@@ -2183,6 +2219,8 @@ public final  E subscribeWith(E observer) {
 
     /**
      * Subscribes to this Completable and calls back either the onError or onComplete functions.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -2207,6 +2245,8 @@ public final Disposable subscribe(final Action onComplete, final Consumer
+     * 
+     * 

      * If the Completable emits an error, it is wrapped into an
      * {@link io.reactivex.exceptions.OnErrorNotImplementedException OnErrorNotImplementedException}
      * and routed to the RxJavaPlugins.onError handler.
@@ -2277,6 +2317,8 @@ public final Completable takeUntil(CompletableSource other) {
     /**
      * Returns a Completable that runs this Completable and emits a TimeoutException in case
      * this Completable doesn't complete within the given time.
+     * 

+     * 
      * 

      *  
Scheduler:

      *  
{@code timeout} signals the TimeoutException on the {@code computation} {@link Scheduler}.

@@ -2295,6 +2337,8 @@ public final Completable timeout(long timeout, TimeUnit unit) {
     /**
      * Returns a Completable that runs this Completable and switches to the other Completable
      * in case this Completable doesn't complete within the given time.
+     * 

+     * 
      * 

      *  
Scheduler:

      *  
{@code timeout} subscribes to the other CompletableSource on
@@ -2317,6 +2361,8 @@ public final Completable timeout(long timeout, TimeUnit unit, CompletableSource
      * Returns a Completable that runs this Completable and emits a TimeoutException in case
      * this Completable doesn't complete within the given time while "waiting" on the specified
      * Scheduler.
+     * 

+     * 
      * 

      *  
Scheduler:

      *  
{@code timeout} signals the TimeoutException on the {@link Scheduler} you specify.

@@ -2337,6 +2383,8 @@ public final Completable timeout(long timeout, TimeUnit unit, Scheduler schedule
      * Returns a Completable that runs this Completable and switches to the other Completable
      * in case this Completable doesn't complete within the given time while "waiting" on
      * the specified scheduler.
+     * 

+     * 
      * 

      *  
Scheduler:

      *  
{@code timeout} subscribes to the other CompletableSource on
@@ -2542,6 +2590,8 @@ public final Completable unsubscribeOn(final Scheduler scheduler) {
     /**
      * Creates a TestObserver and subscribes
      * it to this Completable.
+     * 

+     * 
      * 

      *  
Scheduler:

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

@@ -2561,6 +2611,8 @@ public final TestObserver test() {
      * Creates a TestObserver optionally in cancelled state, then subscribes it to this Completable.
      * @param cancelled if true, the TestObserver will be cancelled before subscribing to this
      * Completable.
+     * 

+     * 
      * 

      *  
Scheduler:

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