diff --git a/src/main/java/io/reactivex/rxjava3/core/Flowable.java b/src/main/java/io/reactivex/rxjava3/core/Flowable.java
index 97785c1f4c..e38004b214 100644
--- a/src/main/java/io/reactivex/rxjava3/core/Flowable.java
+++ b/src/main/java/io/reactivex/rxjava3/core/Flowable.java
@@ -38,14 +38,14 @@
import io.reactivex.rxjava3.subscribers.*;
/**
- * The Flowable class that implements the Reactive Streams
+ * The {@code Flowable} class that implements the Reactive Streams {@link Publisher}
* Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
*
- * Reactive Streams operates with {@link Publisher}s which {@code Flowable} extends. Many operators
+ * Reactive Streams operates with {@code Publisher}s which {@code Flowable} extends. Many operators
* therefore accept general {@code Publisher}s directly and allow direct interoperation with other
- * Reactive Streams implementations.
+ * Reactive Streams implementations.
*
- * The Flowable hosts the default buffer size of 128 elements for operators, accessible via {@link #bufferSize()},
+ * The {@code Flowable} hosts the default buffer size of 128 elements for operators, accessible via {@link #bufferSize()},
* that can be overridden globally via the system parameter {@code rx3.buffer-size}. Most operators, however, have
* overloads that allow setting their internal buffer size explicitly.
*
@@ -62,7 +62,7 @@
* Unlike the {@code Observable.subscribe()} of version 1.x, {@link #subscribe(Subscriber)} does not allow external cancellation
* of a subscription and the {@link Subscriber} instance is expected to expose such capability if needed.
*
- * Flowables support backpressure and require {@link Subscriber}s to signal demand via {@link Subscription#request(long)}.
+ * {@code Flowable}s support backpressure and require {@code Subscriber}s to signal demand via {@link Subscription#request(long)}.
*
* Example:
*
@@ -90,13 +90,13 @@
* d.dispose();
*
*
- * The Reactive Streams specification is relatively strict when defining interactions between {@code Publisher}s and {@code Subscriber}s, so much so
+ * The Reactive Streams specification is relatively strict when defining interactions between {@code Publisher}s and {@code Subscriber}s, so much so
* that there is a significant performance penalty due certain timing requirements and the need to prepare for invalid
* request amounts via {@link Subscription#request(long)}.
* Therefore, RxJava has introduced the {@link FlowableSubscriber} interface that indicates the consumer can be driven with relaxed rules.
* All RxJava operators are implemented with these relaxed rules in mind.
- * If the subscribing {@code Subscriber} does not implement this interface, for example, due to it being from another Reactive Streams compliant
- * library, the Flowable will automatically apply a compliance wrapper around it.
+ * If the subscribing {@code Subscriber} does not implement this interface, for example, due to it being from another Reactive Streams compliant
+ * library, the {@code Flowable} will automatically apply a compliance wrapper around it.
*
* {@code Flowable} is an abstract class, but it is not advised to implement sources and custom operators by extending the class directly due
* to the large amounts of Reactive Streams
@@ -142,11 +142,10 @@
* has to be explicitly expressed via operators such as {@link #subscribeOn(Scheduler)}, {@link #observeOn(Scheduler)} and {@link #parallel()}. In general,
* operators featuring a {@link Scheduler} parameter are introducing this type of asynchrony into the flow.
*
- * For more information see the ReactiveX
- * documentation.
+ * For more information see the ReactiveX documentation.
*
* @param
- * the type of the items emitted by the Flowable
+ * the type of the items emitted by the {@code Flowable}
* @see Observable
* @see ParallelFlowable
* @see io.reactivex.rxjava3.subscribers.DisposableSubscriber
@@ -159,7 +158,7 @@ public abstract class Flowable implements Publisher {
}
/**
- * Mirrors the one Publisher in an Iterable of several Publishers that first either emits an item or sends
+ * Mirrors the one {@link Publisher} in an {@link Iterable} of several {@code Publisher}s that first either emits an item or sends
* a termination notification.
*
* 
@@ -173,9 +172,9 @@ public abstract class Flowable implements Publisher {
*
* @param the common element type
* @param sources
- * an Iterable of Publishers sources competing to react first. A subscription to each Publisher will
- * occur in the same order as in this Iterable.
- * @return a Flowable that emits the same sequence as whichever of the source Publishers first
+ * an {@code Iterable} of {@code Publisher}s sources competing to react first. A subscription to each {@code Publisher} will
+ * occur in the same order as in this {@code Iterable}.
+ * @return a {@code Flowable} that emits the same sequence as whichever of the source {@code Publisher}s first
* emitted an item or sent a termination notification
* @see ReactiveX operators documentation: Amb
*/
@@ -189,7 +188,7 @@ public static Flowable amb(@NonNull Iterable
*
@@ -203,9 +202,9 @@ public static Flowable amb(@NonNull Iterable the common element type
* @param sources
- * an array of Publisher sources competing to react first. A subscription to each Publisher will
- * occur in the same order as in this Iterable.
- * @return a Flowable that emits the same sequence as whichever of the source Publishers first
+ * an array of {@code Publisher} sources competing to react first. A subscription to each {@code Publisher} will
+ * occur in the same order as in this array.
+ * @return a {@code Flowable} that emits the same sequence as whichever of the source {@code Publisher}s first
* emitted an item or sent a termination notification
* @see ReactiveX operators documentation: Amb
*/
@@ -229,7 +228,7 @@ public static Flowable ambArray(Publisher... sources) {
/**
* Returns the default internal buffer size used by most async operators.
* The value can be overridden via system parameter {@code rx3.buffer-size}
- * before the Flowable class is loaded.
+ * before the {@code Flowable} class is loaded.
* @return the default internal buffer size.
*/
@CheckReturnValue
@@ -238,26 +237,26 @@ public static int bufferSize() {
}
/**
- * Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
- * the source Publishers each time an item is received from any of the source Publishers, where this
+ * Combines a collection of source {@link Publisher}s by emitting an item that aggregates the latest values of each of
+ * the source {@code Publisher}s each time an item is received from any of the source {@code Publisher}s, where this
* aggregation is defined by a specified function.
*
* Note on method signature: since Java doesn't allow creating a generic array with {@code new T[]}, the
* implementation of this operator has to create an {@code Object[]} instead. Unfortunately, a
- * {@code Function} passed to the method would trigger a {@code ClassCastException}.
+ * {@code Function} passed to the method would trigger a {@link ClassCastException}.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- * If the provided array of source Publishers is empty, the resulting sequence completes immediately without emitting
+ * If the provided array of source {@code Publisher}s is empty, the resulting sequence completes immediately without emitting
* any items and without any calls to the combiner function.
*
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* - Scheduler:
* - {@code combineLatestArray} does not operate by default on a particular {@link Scheduler}.
*
@@ -267,11 +266,11 @@ public static int bufferSize() {
* @param
* the result type
* @param sources
- * the collection of source Publishers
+ * the collection of source {@code Publisher}s
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SchedulerSupport(SchedulerSupport.NONE)
@@ -283,26 +282,26 @@ public static int bufferSize() {
}
/**
- * Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
- * the source Publishers each time an item is received from any of the source Publishers, where this
+ * Combines a collection of source {@link Publisher}s by emitting an item that aggregates the latest values of each of
+ * the source {@code Publisher}s each time an item is received from any of the source {@code Publisher}s, where this
* aggregation is defined by a specified function.
*
* Note on method signature: since Java doesn't allow creating a generic array with {@code new T[]}, the
* implementation of this operator has to create an {@code Object[]} instead. Unfortunately, a
- * {@code Function} passed to the method would trigger a {@code ClassCastException}.
+ * {@code Function} passed to the method would trigger a {@link ClassCastException}.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- * If the provided array of source Publishers is empty, the resulting sequence completes immediately without emitting
+ * If the provided array of source {@code Publisher}s is empty, the resulting sequence completes immediately without emitting
* any items and without any calls to the combiner function.
*
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* - Scheduler:
* - {@code combineLatestArray} does not operate by default on a particular {@link Scheduler}.
*
@@ -312,13 +311,13 @@ public static int bufferSize() {
* @param
* the result type
* @param sources
- * the collection of source Publishers
+ * the collection of source {@code Publisher}s
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
* @param bufferSize
- * the internal buffer size and prefetch amount applied to every source Flowable
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the internal buffer size and prefetch amount applied to every source {@code Flowable}
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SchedulerSupport(SchedulerSupport.NONE)
@@ -336,26 +335,26 @@ public static Flowable combineLatestArray(@NonNull Publisher
* Note on method signature: since Java doesn't allow creating a generic array with {@code new T[]}, the
* implementation of this operator has to create an {@code Object[]} instead. Unfortunately, a
- * {@code Function} passed to the method would trigger a {@code ClassCastException}.
+ * {@code Function} passed to the method would trigger a {@link ClassCastException}.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- * If the provided iterable of source Publishers is empty, the resulting sequence completes immediately without emitting
+ * If the provided iterable of source {@code Publisher}s is empty, the resulting sequence completes immediately without emitting
* any items and without any calls to the combiner function.
*
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* - Scheduler:
* - {@code combineLatest} does not operate by default on a particular {@link Scheduler}.
*
@@ -365,11 +364,11 @@ public static Flowable combineLatestArray(@NonNull Publisher
* the result type
* @param sources
- * the collection of source Publishers
+ * the collection of source {@code Publisher}s
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SchedulerSupport(SchedulerSupport.NONE)
@@ -382,26 +381,26 @@ public static Flowable combineLatestArray(@NonNull Publisher
* Note on method signature: since Java doesn't allow creating a generic array with {@code new T[]}, the
* implementation of this operator has to create an {@code Object[]} instead. Unfortunately, a
- * {@code Function} passed to the method would trigger a {@code ClassCastException}.
+ * {@code Function} passed to the method would trigger a {@link ClassCastException}.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- * If the provided iterable of source Publishers is empty, the resulting sequence completes immediately without emitting any items and
+ * If the provided iterable of source {@code Publisher}s is empty, the resulting sequence completes immediately without emitting any items and
* without any calls to the combiner function.
*
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* - Scheduler:
* - {@code combineLatest} does not operate by default on a particular {@link Scheduler}.
*
@@ -411,13 +410,13 @@ public static Flowable combineLatestArray(@NonNull Publisher
* the result type
* @param sources
- * the collection of source Publishers
+ * the collection of source {@code Publisher}s
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
* @param bufferSize
- * the internal buffer size and prefetch amount applied to every source Flowable
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the internal buffer size and prefetch amount applied to every source {@code Flowable}
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SchedulerSupport(SchedulerSupport.NONE)
@@ -433,26 +432,26 @@ public static Flowable combineLatest(@NonNull Iterable
* Note on method signature: since Java doesn't allow creating a generic array with {@code new T[]}, the
* implementation of this operator has to create an {@code Object[]} instead. Unfortunately, a
- * {@code Function} passed to the method would trigger a {@code ClassCastException}.
+ * {@code Function} passed to the method would trigger a {@link ClassCastException}.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- * If the provided array of source Publishers is empty, the resulting sequence completes immediately without emitting
+ * If the provided array of source {@code Publisher}s is empty, the resulting sequence completes immediately without emitting
* any items and without any calls to the combiner function.
*
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* - Scheduler:
* - {@code combineLatestDelayError} does not operate by default on a particular {@link Scheduler}.
*
@@ -462,11 +461,11 @@ public static Flowable combineLatest(@NonNull Iterable
* the result type
* @param sources
- * the collection of source Publishers
+ * the collection of source {@code Publisher}s
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SchedulerSupport(SchedulerSupport.NONE)
@@ -479,27 +478,27 @@ public static Flowable combineLatest(@NonNull Iterable
* Note on method signature: since Java doesn't allow creating a generic array with {@code new T[]}, the
* implementation of this operator has to create an {@code Object[]} instead. Unfortunately, a
- * {@code Function} passed to the method would trigger a {@code ClassCastException}.
+ * {@code Function} passed to the method would trigger a {@link ClassCastException}.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- * If the provided array of source Publishers is empty, the resulting sequence completes immediately without emitting
+ * If the provided array of source {@code Publisher}s is empty, the resulting sequence completes immediately without emitting
* any items and without any calls to the combiner function.
*
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* - Scheduler:
* - {@code combineLatestDelayError} does not operate by default on a particular {@link Scheduler}.
*
@@ -509,13 +508,13 @@ public static Flowable combineLatest(@NonNull Iterable
* the result type
* @param sources
- * the collection of source Publishers
+ * the collection of source {@code Publisher}s
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
* @param bufferSize
- * the internal buffer size and prefetch amount applied to every source Flowable
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the internal buffer size and prefetch amount applied to every source {@code Flowable}
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SchedulerSupport(SchedulerSupport.NONE)
@@ -534,27 +533,27 @@ public static Flowable combineLatest(@NonNull Iterable
* Note on method signature: since Java doesn't allow creating a generic array with {@code new T[]}, the
* implementation of this operator has to create an {@code Object[]} instead. Unfortunately, a
- * {@code Function} passed to the method would trigger a {@code ClassCastException}.
+ * {@code Function} passed to the method would trigger a {@link ClassCastException}.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- * If the provided iterable of source Publishers is empty, the resulting sequence completes immediately without emitting
+ * If the provided iterable of source {@code Publisher}s is empty, the resulting sequence completes immediately without emitting
* any items and without any calls to the combiner function.
*
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* - Scheduler:
* - {@code combineLatestDelayError} does not operate by default on a particular {@link Scheduler}.
*
@@ -564,11 +563,11 @@ public static Flowable combineLatest(@NonNull Iterable
* the result type
* @param sources
- * the collection of source Publishers
+ * the collection of source {@code Publisher}s
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SchedulerSupport(SchedulerSupport.NONE)
@@ -581,27 +580,27 @@ public static Flowable combineLatest(@NonNull Iterable
* Note on method signature: since Java doesn't allow creating a generic array with {@code new T[]}, the
* implementation of this operator has to create an {@code Object[]} instead. Unfortunately, a
- * {@code Function} passed to the method would trigger a {@code ClassCastException}.
+ * {@code Function} passed to the method would trigger a {@link ClassCastException}.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- * If the provided iterable of source Publishers is empty, the resulting sequence completes immediately without emitting
+ * If the provided iterable of source {@code Publisher}s is empty, the resulting sequence completes immediately without emitting
* any items and without any calls to the combiner function.
*
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* - Scheduler:
* - {@code combineLatestDelayError} does not operate by default on a particular {@link Scheduler}.
*
@@ -611,13 +610,13 @@ public static Flowable combineLatest(@NonNull Iterable
* the result type
* @param sources
- * the collection of source Publishers
+ * the collection of source {@code Publisher}s
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
* @param bufferSize
- * the internal buffer size and prefetch amount applied to every source Flowable
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the internal buffer size and prefetch amount applied to every source {@code Flowable}
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SchedulerSupport(SchedulerSupport.NONE)
@@ -633,8 +632,8 @@ public static Flowable combineLatestDelayError(@NonNull Iterable
* If any of the sources never produces an item but only terminates (normally or with an error), the
@@ -646,7 +645,7 @@ public static Flowable combineLatestDelayError(@NonNull IterableBackpressure:
* The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* Scheduler:
* {@code combineLatest} does not operate by default on a particular {@link Scheduler}.
*
@@ -655,13 +654,13 @@ public static Flowable combineLatestDelayError(@NonNull Iterable the element type of the second source
* @param the combined output type
* @param source1
- * the first source Publisher
+ * the first source {@code Publisher}
* @param source2
- * the second source Publisher
+ * the second source {@code Publisher}
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SuppressWarnings("unchecked")
@@ -679,8 +678,8 @@ public static Flowable combineLatest(
}
/**
- * Combines three source Publishers by emitting an item that aggregates the latest values of each of the
- * source Publishers each time an item is received from any of the source Publishers, where this
+ * Combines three source {@link Publisher}s by emitting an item that aggregates the latest values of each of the
+ * source {@code Publisher}s each time an item is received from any of the source {@code Publisher}s, where this
* aggregation is defined by a specified function.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
@@ -692,7 +691,7 @@ public static Flowable combineLatest(
* Backpressure:
* The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* Scheduler:
* {@code combineLatest} does not operate by default on a particular {@link Scheduler}.
*
@@ -702,15 +701,15 @@ public static Flowable combineLatest(
* @param the element type of the third source
* @param the combined output type
* @param source1
- * the first source Publisher
+ * the first source {@code Publisher}
* @param source2
- * the second source Publisher
+ * the second source {@code Publisher}
* @param source3
- * the third source Publisher
+ * the third source {@code Publisher}
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SuppressWarnings("unchecked")
@@ -730,8 +729,8 @@ public static Flowable combineLatest(
}
/**
- * Combines four source Publishers by emitting an item that aggregates the latest values of each of the
- * source Publishers each time an item is received from any of the source Publishers, where this
+ * Combines four source {@link Publisher}s by emitting an item that aggregates the latest values of each of the
+ * source {@code Publisher}s each time an item is received from any of the source {@code Publisher}s, where this
* aggregation is defined by a specified function.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
@@ -743,7 +742,7 @@ public static Flowable combineLatest(
* Backpressure:
* The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* Scheduler:
* {@code combineLatest} does not operate by default on a particular {@link Scheduler}.
*
@@ -754,17 +753,17 @@ public static Flowable combineLatest(
* @param the element type of the fourth source
* @param the combined output type
* @param source1
- * the first source Publisher
+ * the first source {@code Publisher}
* @param source2
- * the second source Publisher
+ * the second source {@code Publisher}
* @param source3
- * the third source Publisher
+ * the third source {@code Publisher}
* @param source4
- * the fourth source Publisher
+ * the fourth source {@code Publisher}
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SuppressWarnings("unchecked")
@@ -785,8 +784,8 @@ public static Flowable combineLatest(
}
/**
- * Combines five source Publishers by emitting an item that aggregates the latest values of each of the
- * source Publishers each time an item is received from any of the source Publishers, where this
+ * Combines five source {@link Publisher}s by emitting an item that aggregates the latest values of each of the
+ * source {@code Publisher}s each time an item is received from any of the source {@code Publisher}s, where this
* aggregation is defined by a specified function.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
@@ -798,7 +797,7 @@ public static Flowable combineLatest(
* Backpressure:
* The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* Scheduler:
* {@code combineLatest} does not operate by default on a particular {@link Scheduler}.
*
@@ -810,19 +809,19 @@ public static Flowable combineLatest(
* @param the element type of the fifth source
* @param the combined output type
* @param source1
- * the first source Publisher
+ * the first source {@code Publisher}
* @param source2
- * the second source Publisher
+ * the second source {@code Publisher}
* @param source3
- * the third source Publisher
+ * the third source {@code Publisher}
* @param source4
- * the fourth source Publisher
+ * the fourth source {@code Publisher}
* @param source5
- * the fifth source Publisher
+ * the fifth source {@code Publisher}
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SuppressWarnings("unchecked")
@@ -845,8 +844,8 @@ public static Flowable combineLatest(
}
/**
- * Combines six source Publishers by emitting an item that aggregates the latest values of each of the
- * source Publishers each time an item is received from any of the source Publishers, where this
+ * Combines six source {@link Publisher}s by emitting an item that aggregates the latest values of each of the
+ * source {@code Publisher}s each time an item is received from any of the source {@code Publisher}s, where this
* aggregation is defined by a specified function.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
@@ -858,7 +857,7 @@ public static Flowable combineLatest(
* Backpressure:
* The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* Scheduler:
* {@code combineLatest} does not operate by default on a particular {@link Scheduler}.
*
@@ -871,21 +870,21 @@ public static Flowable combineLatest(
* @param the element type of the sixth source
* @param the combined output type
* @param source1
- * the first source Publisher
+ * the first source {@code Publisher}
* @param source2
- * the second source Publisher
+ * the second source {@code Publisher}
* @param source3
- * the third source Publisher
+ * the third source {@code Publisher}
* @param source4
- * the fourth source Publisher
+ * the fourth source {@code Publisher}
* @param source5
- * the fifth source Publisher
+ * the fifth source {@code Publisher}
* @param source6
- * the sixth source Publisher
+ * the sixth source {@code Publisher}
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SuppressWarnings("unchecked")
@@ -909,8 +908,8 @@ public static Flowable combineLatest(
}
/**
- * Combines seven source Publishers by emitting an item that aggregates the latest values of each of the
- * source Publishers each time an item is received from any of the source Publishers, where this
+ * Combines seven source {@link Publisher}s by emitting an item that aggregates the latest values of each of the
+ * source {@code Publisher}s each time an item is received from any of the source {@code Publisher}s, where this
* aggregation is defined by a specified function.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
@@ -922,7 +921,7 @@ public static Flowable combineLatest(
* Backpressure:
* The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* Scheduler:
* {@code combineLatest} does not operate by default on a particular {@link Scheduler}.
*
@@ -936,23 +935,23 @@ public static Flowable combineLatest(
* @param the element type of the seventh source
* @param the combined output type
* @param source1
- * the first source Publisher
+ * the first source {@code Publisher}
* @param source2
- * the second source Publisher
+ * the second source {@code Publisher}
* @param source3
- * the third source Publisher
+ * the third source {@code Publisher}
* @param source4
- * the fourth source Publisher
+ * the fourth source {@code Publisher}
* @param source5
- * the fifth source Publisher
+ * the fifth source {@code Publisher}
* @param source6
- * the sixth source Publisher
+ * the sixth source {@code Publisher}
* @param source7
- * the seventh source Publisher
+ * the seventh source {@code Publisher}
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SuppressWarnings("unchecked")
@@ -978,8 +977,8 @@ public static Flowable combineLatest(
}
/**
- * Combines eight source Publishers by emitting an item that aggregates the latest values of each of the
- * source Publishers each time an item is received from any of the source Publishers, where this
+ * Combines eight source {@link Publisher}s by emitting an item that aggregates the latest values of each of the
+ * source {@code Publisher}s each time an item is received from any of the source {@code Publisher}s, where this
* aggregation is defined by a specified function.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
@@ -991,7 +990,7 @@ public static Flowable combineLatest(
* Backpressure:
* The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* Scheduler:
* {@code combineLatest} does not operate by default on a particular {@link Scheduler}.
*
@@ -1006,25 +1005,25 @@ public static Flowable combineLatest(
* @param the element type of the eighth source
* @param the combined output type
* @param source1
- * the first source Publisher
+ * the first source {@code Publisher}
* @param source2
- * the second source Publisher
+ * the second source {@code Publisher}
* @param source3
- * the third source Publisher
+ * the third source {@code Publisher}
* @param source4
- * the fourth source Publisher
+ * the fourth source {@code Publisher}
* @param source5
- * the fifth source Publisher
+ * the fifth source {@code Publisher}
* @param source6
- * the sixth source Publisher
+ * the sixth source {@code Publisher}
* @param source7
- * the seventh source Publisher
+ * the seventh source {@code Publisher}
* @param source8
- * the eighth source Publisher
+ * the eighth source {@code Publisher}
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SuppressWarnings("unchecked")
@@ -1051,8 +1050,8 @@ public static Flowable combineLatest(
}
/**
- * Combines nine source Publishers by emitting an item that aggregates the latest values of each of the
- * source Publishers each time an item is received from any of the source Publishers, where this
+ * Combines nine source {@link Publisher}s by emitting an item that aggregates the latest values of each of the
+ * source {@code Publisher}s each time an item is received from any of the source {@code Publisher}s, where this
* aggregation is defined by a specified function.
*
* If any of the sources never produces an item but only terminates (normally or with an error), the
@@ -1064,7 +1063,7 @@ public static Flowable combineLatest(
* Backpressure:
* The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
* are requested in a bounded manner, however, their backpressure is not enforced (the operator won't signal
- * {@code MissingBackpressureException}) and may lead to {@code OutOfMemoryError} due to internal buffer bloat.
+ * {@link MissingBackpressureException}) and may lead to {@link OutOfMemoryError} due to internal buffer bloat.
* Scheduler:
* {@code combineLatest} does not operate by default on a particular {@link Scheduler}.
*
@@ -1080,27 +1079,27 @@ public static Flowable combineLatest(
* @param the element type of the ninth source
* @param the combined output type
* @param source1
- * the first source Publisher
+ * the first source {@code Publisher}
* @param source2
- * the second source Publisher
+ * the second source {@code Publisher}
* @param source3
- * the third source Publisher
+ * the third source {@code Publisher}
* @param source4
- * the fourth source Publisher
+ * the fourth source {@code Publisher}
* @param source5
- * the fifth source Publisher
+ * the fifth source {@code Publisher}
* @param source6
- * the sixth source Publisher
+ * the sixth source {@code Publisher}
* @param source7
- * the seventh source Publisher
+ * the seventh source {@code Publisher}
* @param source8
- * the eighth source Publisher
+ * the eighth source {@code Publisher}
* @param source9
- * the ninth source Publisher
+ * the ninth source {@code Publisher}
* @param combiner
- * the aggregation function used to combine the items emitted by the source Publishers
- * @return a Flowable that emits items that are the result of combining the items emitted by the source
- * Publishers by means of the given aggregation function
+ * the aggregation function used to combine the items emitted by the source {@code Publisher}s
+ * @return a {@code Flowable} that emits items that are the result of combining the items emitted by the source
+ * {@code Publisher}s by means of the given aggregation function
* @see ReactiveX operators documentation: CombineLatest
*/
@SuppressWarnings("unchecked")
@@ -1129,7 +1128,7 @@ public static Flowable combineLatest(
}
/**
- * Concatenates elements of each Publisher provided via an Iterable sequence into a single sequence
+ * Concatenates elements of each {@link Publisher} provided via an {@link Iterable} sequence into a single sequence
* of elements without interleaving them.
*
* 
@@ -1138,13 +1137,13 @@ public static Flowable combineLatest(
* The operator honors backpressure from downstream. The {@code Publisher}
* sources are expected to honor backpressure as well.
* If any of the source {@code Publisher}s violate this, it may throw an
- * {@code IllegalStateException} when the source {@code Publisher} completes.
+ * {@link IllegalStateException} when the source {@code Publisher} completes.
* Scheduler:
* {@code concat} does not operate by default on a particular {@link Scheduler}.
*
* @param the common value type of the sources
- * @param sources the Iterable sequence of Publishers
- * @return the new Flowable instance
+ * @param sources the {@code Iterable} sequence of {@code Publisher}s
+ * @return the new {@code Flowable} instance
*/
@SuppressWarnings({ "unchecked", "rawtypes" })
@CheckReturnValue
@@ -1158,25 +1157,25 @@ public static Flowable concat(@NonNull Iterable
*
*
* - Backpressure:
* - The operator honors backpressure from downstream. Both the outer and inner {@code Publisher}
* sources are expected to honor backpressure as well. If the outer violates this, a
- * {@code MissingBackpressureException} is signaled. If any of the inner {@code Publisher}s violates
- * this, it may throw an {@code IllegalStateException} when an inner {@code Publisher} completes.
+ * {@link MissingBackpressureException} is signaled. If any of the inner {@code Publisher}s violates
+ * this, it may throw an {@link IllegalStateException} when an inner {@code Publisher} completes.
* - Scheduler:
* - {@code concat} does not operate by default on a particular {@link Scheduler}.
*
*
* @param the common element base type
* @param sources
- * a Publisher that emits Publishers
- * @return a Flowable that emits items all of the items emitted by the Publishers emitted by
- * {@code Publishers}, one after the other, without interleaving them
+ * a {@code Publisher} that emits {@code Publisher}s
+ * @return a {@code Flowable} that emits items all of the items emitted by the {@code Publisher}s emitted by
+ * {@code Publisher}s, one after the other, without interleaving them
* @see ReactiveX operators documentation: Concat
*/
@CheckReturnValue
@@ -1188,27 +1187,27 @@ public static Flowable concat(@NonNull Publisher
*
*
* - Backpressure:
* - The operator honors backpressure from downstream. Both the outer and inner {@code Publisher}
* sources are expected to honor backpressure as well. If the outer violates this, a
- * {@code MissingBackpressureException} is signaled. If any of the inner {@code Publisher}s violates
- * this, it may throw an {@code IllegalStateException} when an inner {@code Publisher} completes.
+ * {@link MissingBackpressureException} is signaled. If any of the inner {@code Publisher}s violates
+ * this, it may throw an {@link IllegalStateException} when an inner {@code Publisher} completes.
* - Scheduler:
* - {@code concat} does not operate by default on a particular {@link Scheduler}.
*
*
* @param the common element base type
* @param sources
- * a Publisher that emits Publishers
+ * a {@code Publisher} that emits {@code Publisher}s
* @param prefetch
- * the number of Publishers to prefetch from the sources sequence.
- * @return a Flowable that emits items all of the items emitted by the Publishers emitted by
- * {@code Publishers}, one after the other, without interleaving them
+ * the number of {@code Publisher}s to prefetch from the sources sequence.
+ * @return a {@code Flowable} that emits items all of the items emitted by the {@code Publisher}s emitted by
+ * {@code Publisher}s, one after the other, without interleaving them
* @see ReactiveX operators documentation: Concat
*/
@SuppressWarnings({ "unchecked", "rawtypes" })
@@ -1221,7 +1220,7 @@ public static Flowable concat(@NonNull Publisher
*
@@ -1230,17 +1229,17 @@ public static Flowable concat(@NonNull PublisherThe operator honors backpressure from downstream. The {@code Publisher}
* sources are expected to honor backpressure as well.
* If any of the source {@code Publisher}s violate this, it may throw an
- * {@code IllegalStateException} when the source {@code Publisher} completes.
+ * {@link IllegalStateException} when the source {@code Publisher} completes.
* Scheduler:
* {@code concat} does not operate by default on a particular {@link Scheduler}.
*
*
* @param the common element base type
* @param source1
- * a Publisher to be concatenated
+ * a {@code Publisher} to be concatenated
* @param source2
- * a Publisher to be concatenated
- * @return a Flowable that emits items emitted by the two source Publishers, one after the other,
+ * a {@code Publisher} to be concatenated
+ * @return a {@code Flowable} that emits items emitted by the two source {@code Publisher}s, one after the other,
* without interleaving them
* @see ReactiveX operators documentation: Concat
*/
@@ -1255,7 +1254,7 @@ public static Flowable concat(@NonNull Publisher source1, @N
}
/**
- * Returns a Flowable that emits the items emitted by three Publishers, one after the other, without
+ * Returns a {@code Flowable} that emits the items emitted by three {@link Publisher}s, one after the other, without
* interleaving them.
*
*
@@ -1264,19 +1263,19 @@ public static Flowable concat(@NonNull Publisher source1, @N
* The operator honors backpressure from downstream. The {@code Publisher}
* sources are expected to honor backpressure as well.
* If any of the source {@code Publisher}s violate this, it may throw an
- * {@code IllegalStateException} when the source {@code Publisher} completes.
+ * {@link IllegalStateException} when the source {@code Publisher} completes.
* Scheduler:
* {@code concat} does not operate by default on a particular {@link Scheduler}.
*
*
* @param the common element base type
* @param source1
- * a Publisher to be concatenated
+ * a {@code Publisher} to be concatenated
* @param source2
- * a Publisher to be concatenated
+ * a {@code Publisher} to be concatenated
* @param source3
- * a Publisher to be concatenated
- * @return a Flowable that emits items emitted by the three source Publishers, one after the other,
+ * a {@code Publisher} to be concatenated
+ * @return a {@code Flowable} that emits items emitted by the three source {@code Publisher}s, one after the other,
* without interleaving them
* @see ReactiveX operators documentation: Concat
*/
@@ -1294,7 +1293,7 @@ public static Flowable concat(
}
/**
- * Returns a Flowable that emits the items emitted by four Publishers, one after the other, without
+ * Returns a {@code Flowable} that emits the items emitted by four {@link Publisher}s, one after the other, without
* interleaving them.
*
*
@@ -1303,21 +1302,21 @@ public static Flowable concat(
* The operator honors backpressure from downstream. The {@code Publisher}
* sources are expected to honor backpressure as well.
* If any of the source {@code Publisher}s violate this, it may throw an
- * {@code IllegalStateException} when the source {@code Publisher} completes.
+ * {@link IllegalStateException} when the source {@code Publisher} completes.
* Scheduler:
* {@code concat} does not operate by default on a particular {@link Scheduler}.
*
*
* @param the common element base type
* @param source1
- * a Publisher to be concatenated
+ * a {@code Publisher} to be concatenated
* @param source2
- * a Publisher to be concatenated
+ * a {@code Publisher} to be concatenated
* @param source3
- * a Publisher to be concatenated
+ * a {@code Publisher} to be concatenated
* @param source4
- * a Publisher to be concatenated
- * @return a Flowable that emits items emitted by the four source Publishers, one after the other,
+ * a {@code Publisher} to be concatenated
+ * @return a {@code Flowable} that emits items emitted by the four source {@code Publisher}s, one after the other,
* without interleaving them
* @see ReactiveX operators documentation: Concat
*/
@@ -1336,9 +1335,9 @@ public static Flowable concat(
}
/**
- * Concatenates a variable number of Publisher sources.
+ * Concatenates a variable number of {@link Publisher} sources.
*
- * Note: named this way because of overload conflict with concat(Publisher<Publisher>).
+ * Note: named this way because of overload conflict with {@code concat(Publisher>}).
*
*
*
@@ -1346,14 +1345,14 @@ public static Flowable concat(
* - The operator honors backpressure from downstream. The {@code Publisher}
* sources are expected to honor backpressure as well.
* If any of the source {@code Publisher}s violate this, it may throw an
- * {@code IllegalStateException} when the source {@code Publisher} completes.
+ * {@link IllegalStateException} when the source {@code Publisher} completes.
* - Scheduler:
* - {@code concatArray} does not operate by default on a particular {@link Scheduler}.
*
- * @param sources the array of sources
+ * @param sources the array of source {@code Publisher}s
* @param the common base value type
- * @return the new Publisher instance
- * @throws NullPointerException if sources is null
+ * @return the new {@code Publisher} instance
+ * @throws NullPointerException if sources is {@code null}
*/
@CheckReturnValue
@BackpressureSupport(BackpressureKind.FULL)
@@ -1371,7 +1370,7 @@ public static Flowable concatArray(@NonNull Publisher... sou
}
/**
- * Concatenates a variable number of Publisher sources and delays errors from any of them
+ * Concatenates a variable number of {@link Publisher} sources and delays errors from any of them
* till all terminate.
*
*
@@ -1380,14 +1379,14 @@ public static Flowable concatArray(@NonNull Publisher... sou
* The operator honors backpressure from downstream. The {@code Publisher}
* sources are expected to honor backpressure as well.
* If any of the source {@code Publisher}s violate this, it may throw an
- * {@code IllegalStateException} when the source {@code Publisher} completes.
+ * {@link IllegalStateException} when the source {@code Publisher} completes.
* Scheduler:
* {@code concatArrayDelayError} does not operate by default on a particular {@link Scheduler}.
*
- * @param sources the array of sources
+ * @param sources the array of source {@code Publisher}s
* @param the common base value type
- * @return the new Flowable instance
- * @throws NullPointerException if sources is null
+ * @return the new {@code Flowable} instance
+ * @throws NullPointerException if sources is {@code null}
*/
@CheckReturnValue
@BackpressureSupport(BackpressureKind.FULL)
@@ -1405,25 +1404,25 @@ public static Flowable concatArrayDelayError(@NonNull Publisher
* 
*
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
- * source Publishers. The operator buffers the values emitted by these Publishers and then drains them
+ * source {@code Publisher}s. The operator buffers the values emitted by these {@code Publisher}s and then drains them
* in order, each one after the previous one completes.
*
* - Backpressure:
* - The operator honors backpressure from downstream. The {@code Publisher}
* sources are expected to honor backpressure as well.
* If any of the source {@code Publisher}s violate this, the operator will signal a
- * {@code MissingBackpressureException}.
+ * {@link MissingBackpressureException}.
* - Scheduler:
* - This method does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources an array of Publishers that need to be eagerly concatenated
- * @return the new Publisher instance with the specified concatenation behavior
+ * @param sources an array of {@code Publisher}s that need to be eagerly concatenated
+ * @return the new {@code Publisher} instance with the specified concatenation behavior
* @since 2.0
*/
@CheckReturnValue
@@ -1436,28 +1435,28 @@ public static Flowable concatArrayEager(@NonNull Publisher..
}
/**
- * Concatenates an array of Publishers eagerly into a single stream of values.
+ * Concatenates an array of {@link Publisher}s eagerly into a single stream of values.
*
* 
*
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
- * source Publishers. The operator buffers the values emitted by these Publishers and then drains them
+ * source {@code Publisher}s. The operator buffers the values emitted by these {@code Publisher}s and then drains them
* in order, each one after the previous one completes.
*
* - Backpressure:
* - The operator honors backpressure from downstream. The {@code Publisher}
* sources are expected to honor backpressure as well.
* If any of the source {@code Publisher}s violate this, the operator will signal a
- * {@code MissingBackpressureException}.
+ * {@link MissingBackpressureException}.
* - Scheduler:
* - This method does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources an array of Publishers that need to be eagerly concatenated
+ * @param sources an array of {@code Publisher}s that need to be eagerly concatenated
* @param maxConcurrency the maximum number of concurrent subscriptions at a time, {@link Integer#MAX_VALUE}
* is interpreted as an indication to subscribe to all sources at once
- * @param prefetch the number of elements to prefetch from each Publisher source
- * @return the new Publisher instance with the specified concatenation behavior
+ * @param prefetch the number of elements to prefetch from each {@code Publisher} source
+ * @return the new {@code Publisher} instance with the specified concatenation behavior
* @since 2.0
*/
@CheckReturnValue
@@ -1487,13 +1486,13 @@ public static Flowable concatArrayEager(int maxConcurrency, int prefetch,
* The operator honors backpressure from downstream. The {@code Publisher}
* sources are expected to honor backpressure as well.
* If any of the source {@code Publisher}s violate this, the operator will signal a
- * {@code MissingBackpressureException}.
+ * {@link MissingBackpressureException}.
* Scheduler:
* This method does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
* @param sources an array of {@code Publisher}s that need to be eagerly concatenated
- * @return the new Flowable instance with the specified concatenation behavior
+ * @return the new {@code Flowable} instance with the specified concatenation behavior
* @since 2.2.1 - experimental
*/
@CheckReturnValue
@@ -1519,7 +1518,7 @@ public static Flowable concatArrayEagerDelayError(@NonNull PublisherThe operator honors backpressure from downstream. The {@code Publisher}
* sources are expected to honor backpressure as well.
* If any of the source {@code Publisher}s violate this, the operator will signal a
- * {@code MissingBackpressureException}.
+ * {@link MissingBackpressureException}.
* Scheduler:
* This method does not operate by default on a particular {@link Scheduler}.
*
@@ -1528,7 +1527,7 @@ public static Flowable concatArrayEagerDelayError(@NonNull Publisher Flowable concatArrayEagerDelayError(int maxConcurrency, int
}
/**
- * Concatenates the Iterable sequence of Publishers into a single sequence by subscribing to each Publisher,
- * one after the other, one at a time and delays any errors till the all inner Publishers terminate.
+ * Concatenates the {@link Iterable} sequence of {@link Publisher}s into a single sequence by subscribing to each {@code Publisher},
+ * one after the other, one at a time and delays any errors till the all inner {@code Publisher}s terminate.
*
*
* - Backpressure:
* - The operator honors backpressure from downstream. Both the outer and inner {@code Publisher}
* sources are expected to honor backpressure as well. If the outer violates this, a
- * {@code MissingBackpressureException} is signaled. If any of the inner {@code Publisher}s violates
- * this, it may throw an {@code IllegalStateException} when an inner {@code Publisher} completes.
+ * {@link MissingBackpressureException} is signaled. If any of the inner {@code Publisher}s violates
+ * this, it may throw an {@link IllegalStateException} when an inner {@code Publisher} completes.
* - Scheduler:
* - {@code concatDelayError} does not operate by default on a particular {@link Scheduler}.
*
*
* @param the common element base type
- * @param sources the Iterable sequence of Publishers
- * @return the new Publisher with the concatenating behavior
+ * @param sources the {@code Iterable} sequence of {@code Publisher}s
+ * @return the new {@code Publisher} with the concatenating behavior
*/
@SuppressWarnings({ "unchecked", "rawtypes" })
@CheckReturnValue
@@ -1570,8 +1569,8 @@ public static Flowable concatDelayError(@NonNull Iterable
* Backpressure:
@@ -1581,8 +1580,8 @@ public static Flowable concatDelayError(@NonNull Iterable
*
* @param the common element base type
- * @param sources the Publisher sequence of Publishers
- * @return the new Publisher with the concatenating behavior
+ * @param sources the {@code Publisher} sequence of {@code Publisher}s
+ * @return the new {@code Publisher} with the concatenating behavior
*/
@CheckReturnValue
@BackpressureSupport(BackpressureKind.FULL)
@@ -1593,8 +1592,8 @@ public static Flowable concatDelayError(@NonNull Publisher
* Backpressure:
@@ -1604,11 +1603,11 @@ public static Flowable concatDelayError(@NonNull Publisher
*
* @param the common element base type
- * @param sources the Publisher sequence of Publishers
- * @param prefetch the number of elements to prefetch from the outer Publisher
- * @param tillTheEnd if true exceptions from the outer and all inner Publishers are delayed to the end
- * if false, exception from the outer Publisher is delayed till the current Publisher terminates
- * @return the new Publisher with the concatenating behavior
+ * @param sources the {@code Publisher} sequence of {@code Publisher}s
+ * @param prefetch the number of elements to prefetch from the outer {@code Publisher}
+ * @param tillTheEnd if {@code true}, exceptions from the outer and all inner {@code Publisher}s are delayed to the end
+ * if {@code false}, exception from the outer {@code Publisher} is delayed till the current {@code Publisher} terminates
+ * @return the new {@code Publisher} with the concatenating behavior
*/
@SuppressWarnings({ "unchecked", "rawtypes" })
@CheckReturnValue
@@ -1620,22 +1619,22 @@ public static Flowable concatDelayError(@NonNull Publisher
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
- * emitted source Publishers as they are observed. The operator buffers the values emitted by these
- * Publishers and then drains them in order, each one after the previous one completes.
+ * emitted source {@code Publisher}s as they are observed. The operator buffers the values emitted by these
+ * {@code Publisher}s and then drains them in order, each one after the previous one completes.
*
* - Backpressure:
- * - Backpressure is honored towards the downstream and both the outer and inner Publishers are
+ *
- Backpressure is honored towards the downstream and both the outer and inner {@code Publisher}s are
* expected to support backpressure. Violating this assumption, the operator will
- * signal {@code MissingBackpressureException}.
+ * signal {@link MissingBackpressureException}.
* - Scheduler:
* - This method does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources a sequence of Publishers that need to be eagerly concatenated
- * @return the new Publisher instance with the specified concatenation behavior
+ * @param sources a sequence of {@code Publisher}s that need to be eagerly concatenated
+ * @return the new {@code Publisher} instance with the specified concatenation behavior
* @since 2.0
*/
@CheckReturnValue
@@ -1647,25 +1646,25 @@ public static Flowable concatEager(@NonNull Publisher
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
- * emitted source Publishers as they are observed. The operator buffers the values emitted by these
- * Publishers and then drains them in order, each one after the previous one completes.
+ * emitted source {@code Publisher}s as they are observed. The operator buffers the values emitted by these
+ * {@code Publisher}s and then drains them in order, each one after the previous one completes.
*
* - Backpressure:
- * - Backpressure is honored towards the downstream and both the outer and inner Publishers are
+ *
- Backpressure is honored towards the downstream and both the outer and inner {@code Publisher}s are
* expected to support backpressure. Violating this assumption, the operator will
- * signal {@code MissingBackpressureException}.
+ * signal {@link MissingBackpressureException}.
* - Scheduler:
* - This method does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources a sequence of Publishers that need to be eagerly concatenated
- * @param maxConcurrency the maximum number of concurrently running inner Publishers; {@link Integer#MAX_VALUE}
- * is interpreted as all inner Publishers can be active at the same time
- * @param prefetch the number of elements to prefetch from each inner Publisher source
- * @return the new Publisher instance with the specified concatenation behavior
+ * @param sources a sequence of {@code Publisher}s that need to be eagerly concatenated
+ * @param maxConcurrency the maximum number of concurrently running inner {@code Publisher}s; {@link Integer#MAX_VALUE}
+ * is interpreted as all inner {@code Publisher}s can be active at the same time
+ * @param prefetch the number of elements to prefetch from each inner {@code Publisher} source
+ * @return the new {@code Publisher} instance with the specified concatenation behavior
* @since 2.0
*/
@CheckReturnValue
@@ -1681,22 +1680,22 @@ public static Flowable concatEager(@NonNull Publisher
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
- * source Publishers. The operator buffers the values emitted by these Publishers and then drains them
+ * source {@code Publisher}s. The operator buffers the values emitted by these {@code Publisher}s and then drains them
* in order, each one after the previous one completes.
*
* - Backpressure:
- * - Backpressure is honored towards the downstream and the inner Publishers are
+ *
- Backpressure is honored towards the downstream and the inner {@code Publisher}s are
* expected to support backpressure. Violating this assumption, the operator will
- * signal {@code MissingBackpressureException}.
+ * signal {@link MissingBackpressureException}.
* - Scheduler:
* - This method does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources a sequence of Publishers that need to be eagerly concatenated
- * @return the new Publisher instance with the specified concatenation behavior
+ * @param sources a sequence of {@code Publisher}s that need to be eagerly concatenated
+ * @return the new {@code Publisher} instance with the specified concatenation behavior
* @since 2.0
*/
@CheckReturnValue
@@ -1708,25 +1707,25 @@ public static Flowable concatEager(@NonNull Iterable
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
- * source Publishers. The operator buffers the values emitted by these Publishers and then drains them
+ * source {@code Publisher}s. The operator buffers the values emitted by these {@code Publisher}s and then drains them
* in order, each one after the previous one completes.
*
* - Backpressure:
- * - Backpressure is honored towards the downstream and both the outer and inner Publishers are
+ *
- Backpressure is honored towards the downstream and both the outer and inner {@code Publisher}s are
* expected to support backpressure. Violating this assumption, the operator will
- * signal {@code MissingBackpressureException}.
+ * signal {@link MissingBackpressureException}.
* - Scheduler:
* - This method does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources a sequence of Publishers that need to be eagerly concatenated
- * @param maxConcurrency the maximum number of concurrently running inner Publishers; {@link Integer#MAX_VALUE}
- * is interpreted as all inner Publishers can be active at the same time
- * @param prefetch the number of elements to prefetch from each inner Publisher source
- * @return the new Publisher instance with the specified concatenation behavior
+ * @param sources a sequence of {@code Publisher}s that need to be eagerly concatenated
+ * @param maxConcurrency the maximum number of concurrently running inner {@code Publisher}s; {@link Integer#MAX_VALUE}
+ * is interpreted as all inner {@code Publisher}s can be active at the same time
+ * @param prefetch the number of elements to prefetch from each inner {@code Publisher} source
+ * @return the new {@code Publisher} instance with the specified concatenation behavior
* @since 2.0
*/
@CheckReturnValue
@@ -1742,7 +1741,7 @@ public static Flowable concatEager(@NonNull Iterable
* Example:
@@ -1773,10 +1772,11 @@ public static Flowable concatEager(@NonNull Iterable
- * You should call the FlowableEmitter onNext, onError and onComplete methods in a serialized fashion. The
+ * You should call the {@link FlowableEmitter#onNext(Object)}, {@link FlowableEmitter#onError(Throwable)}
+ * and {@link FlowableEmitter#onComplete()} methods in a serialized fashion. The
* rest of its methods are thread-safe.
*
* - Backpressure:
@@ -1786,9 +1786,9 @@ public static Flowable concatEager(@NonNull Iterable
*
* @param the element type
- * @param source the emitter that is called when a Subscriber subscribes to the returned {@code Flowable}
- * @param mode the backpressure mode to apply if the downstream Subscriber doesn't request (fast) enough
- * @return the new Flowable instance
+ * @param source the emitter that is called when a {@code Subscriber} subscribes to the returned {@code Flowable}
+ * @param mode the backpressure mode to apply if the downstream {@code Subscriber} doesn't request (fast) enough
+ * @return the new {@code Flowable} instance
* @see FlowableOnSubscribe
* @see BackpressureStrategy
* @see Cancellable
@@ -1804,14 +1804,14 @@ public static Flowable create(@NonNull FlowableOnSubscribe source, @No
}
/**
- * Returns a Flowable that calls a Publisher factory to create a Publisher for each new Subscriber
- * that subscribes. That is, for each subscriber, the actual Publisher that subscriber observes is
+ * Returns a {@code Flowable} that calls a {@link Publisher} factory to create a {@code Publisher} for each new {@link Subscriber}
+ * that subscribes. That is, for each subscriber, the actual {@code Publisher} that subscriber observes is
* determined by the factory function.
*
* 
*
- * The defer Subscriber allows you to defer or delay emitting items from a Publisher until such time as a
- * Subscriber subscribes to the Publisher. This allows a {@link Subscriber} to easily obtain updates or a
+ * The defer {@code Subscriber} allows you to defer or delay emitting items from a {@code Publisher} until such time as a
+ * {@code Subscriber} subscribes to the {@code Publisher}. This allows a {@code Subscriber} to easily obtain updates or a
* refreshed version of the sequence.
*
* - Backpressure:
@@ -1822,12 +1822,12 @@ public static Flowable create(@NonNull FlowableOnSubscribe source, @No
*
*
* @param supplier
- * the Publisher factory function to invoke for each {@link Subscriber} that subscribes to the
- * resulting Publisher
+ * the {@code Publisher} factory function to invoke for each {@code Subscriber} that subscribes to the
+ * resulting {@code Publisher}
* @param
- * the type of the items emitted by the Publisher
- * @return a Flowable whose {@link Subscriber}s' subscriptions trigger an invocation of the given
- * Publisher factory function
+ * the type of the items emitted by the {@code Publisher}
+ * @return a {@code Flowable} whose {@code Subscriber}s' subscriptions trigger an invocation of the given
+ * {@code Publisher} factory function
* @see ReactiveX operators documentation: Defer
*/
@CheckReturnValue
@@ -1840,7 +1840,7 @@ public static Flowable defer(@NonNull Supplier
* 
@@ -1852,9 +1852,9 @@ public static Flowable defer(@NonNull Supplier
*
* @param
- * the type of the items (ostensibly) emitted by the Publisher
- * @return a Flowable that emits no items to the {@link Subscriber} but immediately invokes the
- * {@link Subscriber}'s {@link Subscriber#onComplete() onComplete} method
+ * the type of the items (ostensibly) emitted by the {@link Publisher}
+ * @return a {@code Flowable} that emits no items to the {@code Subscriber} but immediately invokes the
+ * {@code Subscriber}'s {@link Subscriber#onComplete() onComplete} method
* @see ReactiveX operators documentation: Empty
*/
@CheckReturnValue
@@ -1867,8 +1867,8 @@ public static Flowable empty() {
}
/**
- * Returns a Flowable that invokes a {@link Subscriber}'s {@link Subscriber#onError onError} method when the
- * Subscriber subscribes to it.
+ * Returns a {@code Flowable} that invokes a {@link Subscriber}'s {@link Subscriber#onError onError} method when the
+ * {@code Subscriber} subscribes to it.
*
* 
*
@@ -1879,11 +1879,11 @@ public static Flowable empty() {
*
*
* @param supplier
- * a Supplier factory to return a Throwable for each individual Subscriber
+ * a {@link Supplier} factory to return a {@link Throwable} for each individual {@code Subscriber}
* @param
- * the type of the items (ostensibly) emitted by the Publisher
- * @return a Flowable that invokes the {@link Subscriber}'s {@link Subscriber#onError onError} method when
- * the Subscriber subscribes to it
+ * the type of the items (ostensibly) emitted by the {@link Publisher}
+ * @return a {@code Flowable} that invokes the {@code Subscriber}'s {@link Subscriber#onError onError} method when
+ * the {@code Subscriber} subscribes to it
* @see ReactiveX operators documentation: Throw
*/
@CheckReturnValue
@@ -1896,8 +1896,8 @@ public static Flowable error(@NonNull Supplier suppl
}
/**
- * Returns a Flowable that invokes a {@link Subscriber}'s {@link Subscriber#onError onError} method when the
- * Subscriber subscribes to it.
+ * Returns a {@code Flowable} that invokes a {@link Subscriber}'s {@link Subscriber#onError onError} method when the
+ * {@code Subscriber} subscribes to it.
*
*
*
@@ -1908,11 +1908,11 @@ public static Flowable error(@NonNull Supplier suppl
*
*
* @param throwable
- * the particular Throwable to pass to {@link Subscriber#onError onError}
+ * the particular {@link Throwable} to pass to {@link Subscriber#onError onError}
* @param
- * the type of the items (ostensibly) emitted by the Publisher
- * @return a Flowable that invokes the {@link Subscriber}'s {@link Subscriber#onError onError} method when
- * the Subscriber subscribes to it
+ * the type of the items (ostensibly) emitted by the {@link Publisher}
+ * @return a {@code Flowable} that invokes the {@code Subscriber}'s {@link Subscriber#onError onError} method when
+ * the {@code Subscriber} subscribes to it
* @see ReactiveX operators documentation: Throw
*/
@CheckReturnValue
@@ -1925,7 +1925,7 @@ public static Flowable error(@NonNull Throwable throwable) {
}
/**
- * Converts an Array into a Publisher that emits the items in the Array.
+ * Converts an Array into a {@link Publisher} that emits the items in the Array.
*
* 
*
@@ -1939,8 +1939,8 @@ public static Flowable error(@NonNull Throwable throwable) {
* @param items
* the array of elements
* @param
- * the type of items in the Array and the type of items to be emitted by the resulting Publisher
- * @return a Flowable that emits each item in the source Array
+ * the type of items in the Array and the type of items to be emitted by the resulting {@code Publisher}
+ * @return a {@code Flowable} that emits each item in the source Array
* @see ReactiveX operators documentation: From
*/
@CheckReturnValue
@@ -1960,13 +1960,13 @@ public static Flowable error(@NonNull Throwable throwable) {
}
/**
- * Returns a Flowable that, when a Subscriber subscribes to it, invokes a function you specify and then
+ * Returns a {@code Flowable} that, when a {@link Subscriber} subscribes to it, invokes a function you specify and then
* emits the value returned from that function.
*
* 
*
- * This allows you to defer the execution of the function you specify until a Subscriber subscribes to the
- * Publisher. That is to say, it makes the function "lazy."
+ * This allows you to defer the execution of the function you specify until a {@code Subscriber} subscribes to the
+ * {@link Publisher}. That is to say, it makes the function "lazy."
*
* - Backpressure:
* - The operator honors backpressure from downstream.
@@ -1983,10 +1983,10 @@ public static Flowable error(@NonNull Throwable throwable) {
*
* @param supplier
* a function, the execution of which should be deferred; {@code fromCallable} will invoke this
- * function only when a Subscriber subscribes to the Publisher that {@code fromCallable} returns
+ * function only when a {@code Subscriber} subscribes to the {@code Publisher} that {@code fromCallable} returns
* @param
- * the type of the item emitted by the Publisher
- * @return a Flowable whose {@link Subscriber}s' subscriptions trigger an invocation of the given function
+ * the type of the item emitted by the {@code Publisher}
+ * @return a {@code Flowable} whose {@code Subscriber}s' subscriptions trigger an invocation of the given function
* @see #defer(Supplier)
* @see #fromSupplier(Supplier)
* @since 2.0
@@ -2001,21 +2001,21 @@ public static Flowable error(@NonNull Throwable throwable) {
}
/**
- * Converts a {@link Future} into a Publisher.
+ * Converts a {@link Future} into a {@link Publisher}.
*
* 
*
- * You can convert any object that supports the {@link Future} interface into a Publisher that emits the
+ * You can convert any object that supports the {@code Future} interface into a {@code Publisher} that emits the
* return value of the {@link Future#get} method of that object by passing the object into the {@code from}
* method.
*
- * Important note: This Publisher is blocking on the thread it gets subscribed on; you cannot cancel it.
+ * Important note: This {@code Publisher} is blocking on the thread it gets subscribed on; you cannot cancel it.
*
* Also note that this operator will consume a {@link CompletionStage}-based {@code Future} subclass (such as
* {@link CompletableFuture}) in a blocking manner as well. Use the {@link #fromCompletionStage(CompletionStage)}
* operator to convert and consume such sources in a non-blocking fashion instead.
*
- * Unlike 1.x, canceling the Flowable won't cancel the future. If necessary, one can use composition to achieve the
+ * Unlike 1.x, canceling the {@code Flowable} won't cancel the future. If necessary, one can use composition to achieve the
* cancellation effect: {@code futurePublisher.doOnCancel(() -> future.cancel(true));}.
*
* - Backpressure:
@@ -2025,11 +2025,11 @@ public static Flowable error(@NonNull Throwable throwable) {
*
*
* @param future
- * the source {@link Future}
+ * the source {@code Future}
* @param
- * the type of object that the {@link Future} returns, and also the type of item to be emitted by
- * the resulting Publisher
- * @return a Flowable that emits the item from the source {@link Future}
+ * the type of object that the {@code Future} returns, and also the type of item to be emitted by
+ * the resulting {@code Publisher}
+ * @return a {@code Flowable} that emits the item from the source {@code Future}
* @see ReactiveX operators documentation: From
* @see #fromCompletionStage(CompletionStage)
*/
@@ -2043,18 +2043,18 @@ public static Flowable error(@NonNull Throwable throwable) {
}
/**
- * Converts a {@link Future} into a Publisher, with a timeout on the Future.
+ * Converts a {@link Future} into a {@link Publisher}, with a timeout on the {@code Future}.
*
*
*
- * You can convert any object that supports the {@link Future} interface into a Publisher that emits the
+ * You can convert any object that supports the {@code Future} interface into a {@code Publisher} that emits the
* return value of the {@link Future#get} method of that object by passing the object into the {@code fromFuture}
* method.
*
- * Unlike 1.x, canceling the Flowable won't cancel the future. If necessary, one can use composition to achieve the
+ * Unlike 1.x, canceling the {@code Flowable} won't cancel the future. If necessary, one can use composition to achieve the
* cancellation effect: {@code futurePublisher.doOnCancel(() -> future.cancel(true));}.
*
- * Important note: This Publisher is blocking on the thread it gets subscribed on; you cannot cancel it.
+ * Important note: This {@code Publisher} is blocking on the thread it gets subscribed on; you cannot cancel it.
*
* Also note that this operator will consume a {@link CompletionStage}-based {@code Future} subclass (such as
* {@link CompletableFuture}) in a blocking manner as well. Use the {@link #fromCompletionStage(CompletionStage)}
@@ -2067,15 +2067,15 @@ public static Flowable error(@NonNull Throwable throwable) {
*
*
* @param future
- * the source {@link Future}
+ * the source {@code Future}
* @param timeout
* the maximum time to wait before calling {@code get}
* @param unit
* the {@link TimeUnit} of the {@code timeout} argument
* @param
- * the type of object that the {@link Future} returns, and also the type of item to be emitted by
- * the resulting Publisher
- * @return a Flowable that emits the item from the source {@link Future}
+ * the type of object that the {@code Future} returns, and also the type of item to be emitted by
+ * the resulting {@code Publisher}
+ * @return a {@code Flowable} that emits the item from the source {@code Future}
* @see ReactiveX operators documentation: From
* @see #fromCompletionStage(CompletionStage)
*/
@@ -2090,18 +2090,18 @@ public static Flowable error(@NonNull Throwable throwable) {
}
/**
- * Converts a {@link Future} into a Publisher, with a timeout on the Future.
+ * Converts a {@link Future} into a {@link Publisher}, with a timeout on the {@code Future}.
*
*
*
- * You can convert any object that supports the {@link Future} interface into a Publisher that emits the
+ * You can convert any object that supports the {@code Future} interface into a {@code Publisher} that emits the
* return value of the {@link Future#get} method of that object by passing the object into the {@code from}
* method.
*
- * Unlike 1.x, canceling the Flowable won't cancel the future. If necessary, one can use composition to achieve the
+ * Unlike 1.x, canceling the {@code Flowable} won't cancel the future. If necessary, one can use composition to achieve the
* cancellation effect: {@code futurePublisher.doOnCancel(() -> future.cancel(true));}.
*
- * Important note: This Publisher is blocking; you cannot cancel it.
+ * Important note: This {@code Publisher} is blocking; you cannot cancel it.
*
* Also note that this operator will consume a {@link CompletionStage}-based {@code Future} subclass (such as
* {@link CompletableFuture}) in a blocking manner as well. Use the {@link #fromCompletionStage(CompletionStage)}
@@ -2114,18 +2114,18 @@ public static Flowable error(@NonNull Throwable throwable) {
*
*
* @param future
- * the source {@link Future}
+ * the source {@code Future}
* @param timeout
* the maximum time to wait before calling {@code get}
* @param unit
* the {@link TimeUnit} of the {@code timeout} argument
* @param scheduler
- * the {@link Scheduler} to wait for the Future on. Use a Scheduler such as
- * {@link Schedulers#io()} that can block and wait on the Future
+ * the {@code Scheduler} to wait for the {@code Future} on. Use a {@code Scheduler} such as
+ * {@link Schedulers#io()} that can block and wait on the {@code Future}
* @param
- * the type of object that the {@link Future} returns, and also the type of item to be emitted by
- * the resulting Publisher
- * @return a Flowable that emits the item from the source {@link Future}
+ * the type of object that the {@code Future} returns, and also the type of item to be emitted by
+ * the resulting {@code Publisher}
+ * @return a {@code Flowable} that emits the item from the source {@code Future}
* @see ReactiveX operators documentation: From
* @see #fromCompletionStage(CompletionStage)
*/
@@ -2140,32 +2140,32 @@ public static Flowable error(@NonNull Throwable throwable) {
}
/**
- * Converts a {@link Future}, operating on a specified {@link Scheduler}, into a Publisher.
+ * Converts a {@link Future}, operating on a specified {@link Scheduler}, into a {@link Publisher}.
*
* 
*
- * You can convert any object that supports the {@link Future} interface into a Publisher that emits the
+ * You can convert any object that supports the {@code Future} interface into a {@code Publisher} that emits the
* return value of the {@link Future#get} method of that object by passing the object into the {@code from}
* method.
*
- * Unlike 1.x, canceling the Flowable won't cancel the future. If necessary, one can use composition to achieve the
+ * Unlike 1.x, canceling the {@code Flowable} won't cancel the future. If necessary, one can use composition to achieve the
* cancellation effect: {@code futurePublisher.doOnCancel(() -> future.cancel(true));}.
*
* - Backpressure:
* - The operator honors backpressure from downstream.
* - Scheduler:
- * - You specify which {@link Scheduler} this operator will use.
+ * - You specify which {@code Scheduler} this operator will use.
*
*
* @param future
- * the source {@link Future}
+ * the source {@code Future}
* @param scheduler
- * the {@link Scheduler} to wait for the Future on. Use a Scheduler such as
- * {@link Schedulers#io()} that can block and wait on the Future
+ * the {@code Scheduler} to wait for the {@code Future} on. Use a {@code Scheduler} such as
+ * {@link Schedulers#io()} that can block and wait on the {@code Future}
* @param
- * the type of object that the {@link Future} returns, and also the type of item to be emitted by
- * the resulting Publisher
- * @return a Flowable that emits the item from the source {@link Future}
+ * the type of object that the {@code Future} returns, and also the type of item to be emitted by
+ * the resulting {@code Publisher}
+ * @return a {@code Flowable} that emits the item from the source {@code Future}
* @see ReactiveX operators documentation: From
*/
@SuppressWarnings({ "unchecked" })
@@ -2179,7 +2179,7 @@ public static Flowable error(@NonNull Throwable throwable) {
}
/**
- * Converts an {@link Iterable} sequence into a Publisher that emits the items in the sequence.
+ * Converts an {@link Iterable} sequence into a {@link Publisher} that emits the items in the sequence.
*
*
*
@@ -2191,11 +2191,11 @@ public static Flowable error(@NonNull Throwable throwable) {
*
*
* @param source
- * the source {@link Iterable} sequence
+ * the source {@code Iterable} sequence
* @param
- * the type of items in the {@link Iterable} sequence and the type of items to be emitted by the
- * resulting Publisher
- * @return a Flowable that emits each item in the source {@link Iterable} sequence
+ * the type of items in the {@code Iterable} sequence and the type of items to be emitted by the
+ * resulting {@code Publisher}
+ * @return a {@code Flowable} that emits each item in the source {@code Iterable} sequence
* @see ReactiveX operators documentation: From
* @see #fromStream(Stream)
*/
@@ -2209,17 +2209,17 @@ public static Flowable error(@NonNull Throwable throwable) {
}
/**
- * Converts an arbitrary Reactive Streams Publisher into a Flowable if not already a
- * Flowable.
+ * Converts an arbitrary Reactive Streams {@link Publisher} into a {@code Flowable} if not already a
+ * {@code Flowable}.
*
- * The {@link Publisher} must follow the
+ * The {@code Publisher} must follow the
* Reactive-Streams specification.
* Violating the specification may result in undefined behavior.
*
* If possible, use {@link #create(FlowableOnSubscribe, BackpressureStrategy)} to create a
* source-like {@code Flowable} instead.
*
- * Note that even though {@link Publisher} appears to be a functional interface, it
+ * Note that even though {@code Publisher} appears to be a functional interface, it
* is not recommended to implement it through a lambda as the specification requires
* state management that is not achievable with a stateless lambda.
*
@@ -2230,9 +2230,9 @@ public static Flowable error(@NonNull Throwable throwable) {
* - {@code fromPublisher} does not operate by default on a particular {@link Scheduler}.
*
* @param the value type of the flow
- * @param source the Publisher to convert
- * @return the new Flowable instance
- * @throws NullPointerException if the {@code source} {@code Publisher} is null
+ * @param source the {@code Publisher} to convert
+ * @return the new {@code Flowable} instance
+ * @throws NullPointerException if the {@code source} {@code Publisher} is {@code null}
* @see #create(FlowableOnSubscribe, BackpressureStrategy)
*/
@CheckReturnValue
@@ -2250,13 +2250,13 @@ public static Flowable fromPublisher(@NonNull Publisher sour
}
/**
- * Returns a Flowable that, when a Subscriber subscribes to it, invokes a supplier function you specify and then
+ * Returns a {@code Flowable} that, when a {@link Subscriber} subscribes to it, invokes a supplier function you specify and then
* emits the value returned from that function.
*
* 
*
- * This allows you to defer the execution of the function you specify until a Subscriber subscribes to the
- * Publisher. That is to say, it makes the function "lazy."
+ * This allows you to defer the execution of the function you specify until a {@code Subscriber} subscribes to the
+ * {@link Publisher}. That is to say, it makes the function "lazy."
*
* - Backpressure:
* - The operator honors backpressure from downstream.
@@ -2273,10 +2273,10 @@ public static Flowable fromPublisher(@NonNull Publisher sour
*
* @param supplier
* a function, the execution of which should be deferred; {@code fromSupplier} will invoke this
- * function only when a Subscriber subscribes to the Publisher that {@code fromSupplier} returns
+ * function only when a {@code Subscriber} subscribes to the {@code Publisher} that {@code fromSupplier} returns
* @param
- * the type of the item emitted by the Publisher
- * @return a Flowable whose {@link Subscriber}s' subscriptions trigger an invocation of the given function
+ * the type of the item emitted by the {@code Publisher}
+ * @return a {@code Flowable} whose {@code Subscriber}s' subscriptions trigger an invocation of the given function
* @see #defer(Supplier)
* @see #fromCallable(Callable)
* @since 3.0.0
@@ -2305,11 +2305,11 @@ public static Flowable fromPublisher(@NonNull Publisher sour
*
*
* @param the generated value type
- * @param generator the Consumer called whenever a particular downstream Subscriber has
+ * @param generator the {@link Consumer} called whenever a particular downstream {@link Subscriber} has
* requested a value. The callback then should call {@code onNext}, {@code onError} or
* {@code onComplete} to signal a value or a terminal event. Signaling multiple {@code onNext}
- * in a call will make the operator signal {@code IllegalStateException}.
- * @return the new Flowable instance
+ * in a call will make the operator signal {@link IllegalStateException}.
+ * @return the new {@code Flowable} instance
*/
@CheckReturnValue
@NonNull
@@ -2336,14 +2336,14 @@ public static Flowable generate(@NonNull Consumer<@NonNull Emitter> ge
* - {@code generate} does not operate by default on a particular {@link Scheduler}.
*
*
- * @param the type of the per-Subscriber state
+ * @param the type of the per-{@link Subscriber} state
* @param the generated value type
- * @param initialState the Supplier to generate the initial state for each Subscriber
- * @param generator the Consumer called with the current state whenever a particular downstream Subscriber has
+ * @param initialState the {@link Supplier} to generate the initial state for each {@code Subscriber}
+ * @param generator the {@link Consumer} called with the current state whenever a particular downstream {@code Subscriber} has
* requested a value. The callback then should call {@code onNext}, {@code onError} or
* {@code onComplete} to signal a value or a terminal event. Signaling multiple {@code onNext}
- * in a call will make the operator signal {@code IllegalStateException}.
- * @return the new Flowable instance
+ * in a call will make the operator signal {@link IllegalStateException}.
+ * @return the new {@code Flowable} instance
*/
@CheckReturnValue
@NonNull
@@ -2369,16 +2369,16 @@ public static Flowable generate(@NonNull Supplier initialState, @No
* {@code generate} does not operate by default on a particular {@link Scheduler}.
*
*
- * @param the type of the per-Subscriber state
+ * @param the type of the per-{@link Subscriber} state
* @param the generated value type
- * @param initialState the Supplier to generate the initial state for each Subscriber
- * @param generator the Consumer called with the current state whenever a particular downstream Subscriber has
+ * @param initialState the {@link Supplier} to generate the initial state for each {@code Subscriber}
+ * @param generator the {@link Consumer} called with the current state whenever a particular downstream {@code Subscriber} has
* requested a value. The callback then should call {@code onNext}, {@code onError} or
* {@code onComplete} to signal a value or a terminal event. Signaling multiple {@code onNext}
- * in a call will make the operator signal {@code IllegalStateException}.
- * @param disposeState the Consumer that is called with the current state when the generator
+ * in a call will make the operator signal {@link IllegalStateException}.
+ * @param disposeState the {@code Consumer} that is called with the current state when the generator
* terminates the sequence or it gets canceled
- * @return the new Flowable instance
+ * @return the new {@code Flowable} instance
*/
@CheckReturnValue
@NonNull
@@ -2404,15 +2404,15 @@ public static Flowable generate(@NonNull Supplier initialState, @No
* {@code generate} does not operate by default on a particular {@link Scheduler}.
*
*
- * @param the type of the per-Subscriber state
+ * @param the type of the per-{@link Subscriber} state
* @param the generated value type
- * @param initialState the Supplier to generate the initial state for each Subscriber
- * @param generator the Function called with the current state whenever a particular downstream Subscriber has
+ * @param initialState the {@link Supplier} to generate the initial state for each {@code Subscriber}
+ * @param generator the {@link Function} called with the current state whenever a particular downstream {@code Subscriber} has
* requested a value. The callback then should call {@code onNext}, {@code onError} or
* {@code onComplete} to signal a value or a terminal event and should return a (new) state for
* the next invocation. Signaling multiple {@code onNext}
- * in a call will make the operator signal {@code IllegalStateException}.
- * @return the new Flowable instance
+ * in a call will make the operator signal {@link IllegalStateException}.
+ * @return the new {@code Flowable} instance
*/
@CheckReturnValue
@BackpressureSupport(BackpressureKind.FULL)
@@ -2436,17 +2436,17 @@ public static Flowable generate(@NonNull Supplier initialState, @No
* {@code generate} does not operate by default on a particular {@link Scheduler}.
*
*
- * @param the type of the per-Subscriber state
+ * @param the type of the per-{@link Subscriber} state
* @param the generated value type
- * @param initialState the Supplier to generate the initial state for each Subscriber
- * @param generator the Function called with the current state whenever a particular downstream Subscriber has
+ * @param initialState the {@link Supplier} to generate the initial state for each {@code Subscriber}
+ * @param generator the {@link Function} called with the current state whenever a particular downstream {@code Subscriber} has
* requested a value. The callback then should call {@code onNext}, {@code onError} or
* {@code onComplete} to signal a value or a terminal event and should return a (new) state for
* the next invocation. Signaling multiple {@code onNext}
- * in a call will make the operator signal {@code IllegalStateException}.
- * @param disposeState the Consumer that is called with the current state when the generator
+ * in a call will make the operator signal {@link IllegalStateException}.
+ * @param disposeState the {@link Consumer} that is called with the current state when the generator
* terminates the sequence or it gets canceled
- * @return the new Flowable instance
+ * @return the new {@code Flowable} instance
*/
@CheckReturnValue
@NonNull
@@ -2460,15 +2460,15 @@ public static Flowable generate(@NonNull Supplier initialState, @No
}
/**
- * Returns a Flowable that emits a {@code 0L} after the {@code initialDelay} and ever-increasing numbers
+ * Returns a {@code Flowable} that emits a {@code 0L} after the {@code initialDelay} and ever-increasing numbers
* after each {@code period} of time thereafter.
*
* 
*
* - Backpressure:
* - The operator generates values based on time and ignores downstream backpressure which
- * may lead to {@code MissingBackpressureException} at some point in the chain.
- * Consumers should consider applying one of the {@code onBackpressureXXX} operators as well.
+ * may lead to {@link MissingBackpressureException} at some point in the chain.
+ * Downstream consumers should consider applying one of the {@code onBackpressureXXX} operators as well.
* - Scheduler:
* - {@code interval} operates by default on the {@code computation} {@link Scheduler}.
*
@@ -2479,7 +2479,7 @@ public static Flowable generate(@NonNull Supplier initialState, @No
* the period of time between emissions of the subsequent numbers
* @param unit
* the time unit for both {@code initialDelay} and {@code period}
- * @return a Flowable that emits a 0L after the {@code initialDelay} and ever-increasing numbers after
+ * @return a {@code Flowable} that emits a 0L after the {@code initialDelay} and ever-increasing numbers after
* each {@code period} of time thereafter
* @see ReactiveX operators documentation: Interval
* @since 1.0.12
@@ -2493,17 +2493,17 @@ public static Flowable interval(long initialDelay, long period, @NonNull T
}
/**
- * Returns a Flowable that emits a {@code 0L} after the {@code initialDelay} and ever-increasing numbers
+ * Returns a {@code Flowable} that emits a {@code 0L} after the {@code initialDelay} and ever-increasing numbers
* after each {@code period} of time thereafter, on a specified {@link Scheduler}.
*
* 
*
* - Backpressure:
* - The operator generates values based on time and ignores downstream backpressure which
- * may lead to {@code MissingBackpressureException} at some point in the chain.
- * Consumers should consider applying one of the {@code onBackpressureXXX} operators as well.
+ * may lead to {@link MissingBackpressureException} at some point in the chain.
+ * Downstream consumers should consider applying one of the {@code onBackpressureXXX} operators as well.
* - Scheduler:
- * - You specify which {@link Scheduler} this operator will use.
+ * - You specify which {@code Scheduler} this operator will use.
*
*
* @param initialDelay
@@ -2513,9 +2513,9 @@ public static Flowable interval(long initialDelay, long period, @NonNull T
* @param unit
* the time unit for both {@code initialDelay} and {@code period}
* @param scheduler
- * the Scheduler on which the waiting happens and items are emitted
- * @return a Flowable that emits a 0L after the {@code initialDelay} and ever-increasing numbers after
- * each {@code period} of time thereafter, while running on the given Scheduler
+ * the {@code Scheduler} on which the waiting happens and items are emitted
+ * @return a {@code Flowable} that emits a 0L after the {@code initialDelay} and ever-increasing numbers after
+ * each {@code period} of time thereafter, while running on the given {@code Scheduler}
* @see ReactiveX operators documentation: Interval
* @since 1.0.12
*/
@@ -2530,12 +2530,12 @@ public static Flowable interval(long initialDelay, long period, @NonNull T
}
/**
- * Returns a Flowable that emits a sequential number every specified interval of time.
+ * Returns a {@code Flowable} that emits a sequential number every specified interval of time.
*
* 
*
* - Backpressure:
- * - The operator signals a {@code MissingBackpressureException} if the downstream
+ *
- The operator signals a {@link MissingBackpressureException} if the downstream
* is not ready to receive the next value.
* - Scheduler:
* - {@code interval} operates by default on the {@code computation} {@link Scheduler}.
@@ -2545,7 +2545,7 @@ public static Flowable interval(long initialDelay, long period, @NonNull T
* the period size in time units (see below)
* @param unit
* time units to use for the interval size
- * @return a Flowable that emits a sequential number each time interval
+ * @return a {@code Flowable} that emits a sequential number each time interval
* @see ReactiveX operators documentation: Interval
*/
@CheckReturnValue
@@ -2557,17 +2557,17 @@ public static Flowable interval(long period, @NonNull TimeUnit unit) {
}
/**
- * Returns a Flowable that emits a sequential number every specified interval of time, on a
- * specified Scheduler.
+ * Returns a {@code Flowable} that emits a sequential number every specified interval of time, on a
+ * specified {@link Scheduler}.
*
* 
*
* - Backpressure:
* - The operator generates values based on time and ignores downstream backpressure which
- * may lead to {@code MissingBackpressureException} at some point in the chain.
- * Consumers should consider applying one of the {@code onBackpressureXXX} operators as well.
+ * may lead to {@link MissingBackpressureException} at some point in the chain.
+ * Downstream consumers should consider applying one of the {@code onBackpressureXXX} operators as well.
* - Scheduler:
- * - You specify which {@link Scheduler} this operator will use.
+ * - You specify which {@code Scheduler} this operator will use.
*
*
* @param period
@@ -2575,8 +2575,8 @@ public static Flowable interval(long period, @NonNull TimeUnit unit) {
* @param unit
* time units to use for the interval size
* @param scheduler
- * the Scheduler to use for scheduling the items
- * @return a Flowable that emits a sequential number each time interval
+ * the {@code Scheduler} to use for scheduling the items
+ * @return a {@code Flowable} that emits a sequential number each time interval
* @see ReactiveX operators documentation: Interval
*/
@CheckReturnValue
@@ -2590,19 +2590,19 @@ public static Flowable interval(long period, @NonNull TimeUnit unit, @NonN
/**
* Signals a range of long values, the first after some initial delay and the rest periodically after.
*
- * The sequence completes immediately after the last value (start + count - 1) has been reached.
+ * The sequence completes immediately after the last value {@code (start + count - 1)} has been reached.
*
* - Backpressure:
- * - The operator signals a {@code MissingBackpressureException} if the downstream can't keep up.
+ * - The operator signals a {@link MissingBackpressureException} if the downstream can't keep up.
* - Scheduler:
* - {@code intervalRange} by default operates on the {@link Schedulers#computation() computation} {@link Scheduler}.
*
* @param start that start value of the range
- * @param count the number of values to emit in total, if zero, the operator emits an onComplete after the initial delay.
+ * @param count the number of values to emit in total, if zero, the operator emits an {@code onComplete} after the initial delay.
* @param initialDelay the initial delay before signaling the first value (the start)
* @param period the period between subsequent values
- * @param unit the unit of measure of the initialDelay and period amounts
- * @return the new Flowable instance
+ * @param unit the unit of measure of the {@code initialDelay} and {@code period} amounts
+ * @return the new {@code Flowable} instance
*/
@CheckReturnValue
@BackpressureSupport(BackpressureKind.ERROR)
@@ -2618,17 +2618,17 @@ public static Flowable intervalRange(long start, long count, long initialD
* The sequence completes immediately after the last value (start + count - 1) has been reached.
*
* - Backpressure:
- * - The operator signals a {@code MissingBackpressureException} if the downstream can't keep up.
+ * - The operator signals a {@link MissingBackpressureException} if the downstream can't keep up.
* - Scheduler:
* - you provide the {@link Scheduler}.
*
* @param start that start value of the range
- * @param count the number of values to emit in total, if zero, the operator emits an onComplete after the initial delay.
+ * @param count the number of values to emit in total, if zero, the operator emits an {@code onComplete} after the initial delay.
* @param initialDelay the initial delay before signaling the first value (the start)
* @param period the period between subsequent values
- * @param unit the unit of measure of the initialDelay and period amounts
- * @param scheduler the target scheduler where the values and terminal signals will be emitted
- * @return the new Flowable instance
+ * @param unit the unit of measure of the {@code initialDelay} and {@code period} amounts
+ * @param scheduler the target {@code Scheduler} where the values and terminal signals will be emitted
+ * @return the new {@code Flowable} instance
*/
@CheckReturnValue
@NonNull
@@ -2653,12 +2653,12 @@ public static Flowable intervalRange(long start, long count, long initialD
}
/**
- * Returns a Flowable that signals the given (constant reference) item and then completes.
+ * Returns a {@code Flowable} that signals the given (constant reference) item and then completes.
*
* 
*
* Note that the item is taken and re-emitted as is and not computed by any means by {@code just}. Use {@link #fromCallable(Callable)}
- * to generate a single item on demand (when {@code Subscriber}s subscribe to it).
+ * to generate a single item on demand (when {@link Subscriber}s subscribe to it).
*
* See the multi-parameter overloads of {@code just} to emit more than one (constant reference) items one after the other.
* Use {@link #fromArray(Object...)} to emit an arbitrary number of items that are known upfront.
@@ -2675,7 +2675,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* the item to emit
* @param
* the type of that item
- * @return a Flowable that emits {@code value} as a single item and then completes
+ * @return a {@code Flowable} that emits {@code value} as a single item and then completes
* @see ReactiveX operators documentation: Just
* @see #just(Object, Object)
* @see #fromCallable(Callable)
@@ -2692,7 +2692,7 @@ public static Flowable intervalRange(long start, long count, long initialD
}
/**
- * Converts two items into a Publisher that emits those items.
+ * Converts two items into a {@link Publisher} that emits those items.
*
* 
*
@@ -2708,7 +2708,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* second item
* @param
* the type of these items
- * @return a Flowable that emits each item
+ * @return a {@code Flowable} that emits each item
* @see