From 996303603d39cff3e3d1b1d0841e087162ecf302 Mon Sep 17 00:00:00 2001 From: akarnokd Date: Wed, 18 Jul 2018 11:25:42 +0200 Subject: [PATCH] 2.x: Add missing Completable marbles (07/18a) --- src/main/java/io/reactivex/Completable.java | 34 +++++++++++++++++++++ 1 file changed, 34 insertions(+) diff --git a/src/main/java/io/reactivex/Completable.java b/src/main/java/io/reactivex/Completable.java index e82664e0a6..c1d6b2fb07 100644 --- a/src/main/java/io/reactivex/Completable.java +++ b/src/main/java/io/reactivex/Completable.java @@ -903,6 +903,8 @@ private static NullPointerException toNpe(Throwable ex) { * Returns a Completable instance which manages a resource along * with a custom Completable instance while the subscription is active. *

+ * + *

* This overload disposes eagerly before the terminal event is emitted. *

*
Scheduler:
@@ -927,6 +929,8 @@ public static Completable using(Callable resourceSupplier, * with a custom Completable instance while the subscription is active and performs eager or lazy * resource disposition. *

+ * + *

* If this overload performs a lazy cancellation after the terminal event is emitted. * Exceptions thrown at this time will be delivered to RxJavaPlugins only. *

@@ -959,6 +963,8 @@ public static Completable using( /** * Wraps the given CompletableSource into a Completable * if not already Completable. + *

+ * *

*
Scheduler:
*
{@code wrap} does not operate by default on a particular {@link Scheduler}.
@@ -980,6 +986,8 @@ public static Completable wrap(CompletableSource source) { /** * Returns a Completable that emits the a terminated event of either this Completable * or the other Completable whichever fires first. + *

+ * *

*
Scheduler:
*
{@code ambWith} does not operate by default on a particular {@link Scheduler}.
@@ -1001,6 +1009,8 @@ public final Completable ambWith(CompletableSource other) { * will subscribe to the {@code next} ObservableSource. An error event from this Completable will be * propagated to the downstream subscriber and will result in skipping the subscription of the * Observable. + *

+ * *

*
Scheduler:
*
{@code andThen} does not operate by default on a particular {@link Scheduler}.
@@ -1022,6 +1032,8 @@ public final Observable andThen(ObservableSource next) { * will subscribe to the {@code next} Flowable. An error event from this Completable will be * propagated to the downstream subscriber and will result in skipping the subscription of the * Publisher. + *

+ * *

*
Backpressure:
*
The returned {@code Flowable} honors the backpressure of the downstream consumer @@ -1047,6 +1059,8 @@ public final Flowable andThen(Publisher next) { * will subscribe to the {@code next} SingleSource. An error event from this Completable will be * propagated to the downstream subscriber and will result in skipping the subscription of the * Single. + *

+ * *

*
Scheduler:
*
{@code andThen} does not operate by default on a particular {@link Scheduler}.
@@ -1068,6 +1082,8 @@ public final Single andThen(SingleSource next) { * will subscribe to the {@code next} MaybeSource. An error event from this Completable will be * propagated to the downstream subscriber and will result in skipping the subscription of the * Maybe. + *

+ * *

*
Scheduler:
*
{@code andThen} does not operate by default on a particular {@link Scheduler}.
@@ -1088,6 +1104,8 @@ public final Maybe andThen(MaybeSource next) { * Returns a Completable that first runs this Completable * and then the other completable. *

+ * + *

* This is an alias for {@link #concatWith(CompletableSource)}. *

*
Scheduler:
@@ -1106,6 +1124,8 @@ public final Completable andThen(CompletableSource next) { /** * Calls the specified converter function during assembly time and returns its resulting value. *

+ * + *

* This allows fluent conversion to any other type. *

*
Scheduler:
@@ -1128,6 +1148,8 @@ public final R as(@NonNull CompletableConverter converter) { /** * Subscribes to and awaits the termination of this Completable instance in a blocking manner and * rethrows any exception emitted. + *

+ * *

*
Scheduler:
*
{@code blockingAwait} does not operate by default on a particular {@link Scheduler}.
@@ -1148,6 +1170,8 @@ public final void blockingAwait() { /** * Subscribes to and awaits the termination of this Completable instance in a blocking manner * with a specific timeout and rethrows any exception emitted within the timeout window. + *

+ * *

*
Scheduler:
*
{@code blockingAwait} does not operate by default on a particular {@link Scheduler}.
@@ -1174,6 +1198,8 @@ public final boolean blockingAwait(long timeout, TimeUnit unit) { /** * Subscribes to this Completable instance and blocks until it terminates, then returns null or * the emitted exception if any. + *

+ * *

*
Scheduler:
*
{@code blockingGet} does not operate by default on a particular {@link Scheduler}.
@@ -1192,6 +1218,8 @@ public final Throwable blockingGet() { /** * Subscribes to this Completable instance and blocks until it terminates or the specified timeout * elapses, then returns null for normal termination or the emitted exception if any. + *

+ * *

*
Scheduler:
*
{@code blockingGet} does not operate by default on a particular {@link Scheduler}.
@@ -1216,6 +1244,8 @@ public final Throwable blockingGet(long timeout, TimeUnit unit) { * subscribes to the result Completable, caches its terminal event * and relays/replays it to observers. *

+ * + *

* Note that this operator doesn't allow disposing the connection * of the upstream source. *

@@ -1235,6 +1265,8 @@ public final Completable cache() { /** * Calls the given transformer function with this instance and returns the function's resulting * Completable. + *

+ * *

*
Scheduler:
*
{@code compose} does not operate by default on a particular {@link Scheduler}.
@@ -2308,6 +2340,8 @@ private Completable timeout0(long timeout, TimeUnit unit, Scheduler scheduler, C /** * Allows fluent conversion to another type via a function callback. + *

+ * *

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