diff --git a/src/main/java/io/reactivex/Maybe.java b/src/main/java/io/reactivex/Maybe.java index 164ef91b3b..de4cbec178 100644 --- a/src/main/java/io/reactivex/Maybe.java +++ b/src/main/java/io/reactivex/Maybe.java @@ -52,6 +52,8 @@ public abstract class Maybe implements MaybeSource { /** * Runs multiple MaybeSources and signals the events of the first one that signals (cancelling * the rest). + *

+ * *

*
Scheduler:
*
{@code amb} does not operate by default on a particular {@link Scheduler}.
@@ -71,6 +73,8 @@ public static Maybe amb(final Iterable /** * Runs multiple MaybeSources and signals the events of the first one that signals (cancelling * the rest). + *

+ * *

*
Scheduler:
*
{@code ambArray} does not operate by default on a particular {@link Scheduler}.
@@ -96,6 +100,8 @@ public static Maybe ambArray(final MaybeSource... sources) { /** * Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources provided by * an Iterable sequence. + *

+ * *

*
Backpressure:
*
The returned {@code Flowable} honors the backpressure of the downstream consumer.
@@ -215,6 +221,8 @@ public static Flowable concat( /** * Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources provided by * a Publisher sequence. + *

+ * *

*
Backpressure:
*
The returned {@code Flowable} honors the backpressure of the downstream consumer and @@ -237,6 +245,8 @@ public static Flowable concat(Publisher + * *
*
Backpressure:
*
The returned {@code Flowable} honors the backpressure of the downstream consumer and @@ -263,6 +273,8 @@ public static Flowable concat(Publisher + *

+ * *

Backpressure:
*
The returned {@code Flowable} honors the backpressure of the downstream consumer.
*
Scheduler:
@@ -291,7 +303,7 @@ public static Flowable concatArray(MaybeSource... sources) { * Concatenates a variable number of MaybeSource sources and delays errors from any of them * till all terminate. *

- * + * *

*
Backpressure:
*
The operator honors backpressure from downstream.
@@ -323,6 +335,8 @@ public static Flowable concatArrayDelayError(MaybeSource... * Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the * source MaybeSources. The operator buffers the value emitted by these MaybeSources and then drains them * in order, each one after the previous one completes. + *

+ * *

*
Backpressure:
*
The operator honors backpressure from downstream.
@@ -344,7 +358,8 @@ public static Flowable concatArrayEager(MaybeSource... sourc /** * Concatenates the Iterable sequence of MaybeSources into a single sequence by subscribing to each MaybeSource, * one after the other, one at a time and delays any errors till the all inner MaybeSources terminate. - * + *

+ * *

*
Backpressure:
*
The operator honors backpressure from downstream.
@@ -368,7 +383,8 @@ public static Flowable concatDelayError(Iterable + * *
*
Backpressure:
*
{@code concatDelayError} fully supports backpressure.
@@ -394,6 +410,8 @@ public static Flowable concatDelayError(Publisher + * *
*
Backpressure:
*
Backpressure is honored towards the downstream.
@@ -418,6 +436,8 @@ public static Flowable concatEager(Iterable + * *
*
Backpressure:
*
Backpressure is honored towards the downstream and the outer Publisher is