diff --git a/src/main/java/io/reactivex/rxjava3/core/Completable.java b/src/main/java/io/reactivex/rxjava3/core/Completable.java
index 7e788ea3b9..ee3af955a9 100644
--- a/src/main/java/io/reactivex/rxjava3/core/Completable.java
+++ b/src/main/java/io/reactivex/rxjava3/core/Completable.java
@@ -165,7 +165,7 @@ public static Completable amb(@NonNull Iterable<@NonNull ? extends CompletableSo
* Scheduler:
* {@code complete} does not operate by default on a particular {@link Scheduler}.
*
- * @return a {@code Completable} instance that completes immediately
+ * @return the shared {@code Completable} instance
*/
@CheckReturnValue
@NonNull
@@ -183,7 +183,7 @@ public static Completable complete() {
* {@code concatArray} does not operate by default on a particular {@link Scheduler}.
*
* @param sources the sources to concatenate
- * @return the {@code Completable} instance which completes only when all sources complete
+ * @return the new {@code Completable} instance
* @throws NullPointerException if {@code sources} is {@code null}
*/
@CheckReturnValue
@@ -210,7 +210,7 @@ public static Completable concatArray(@NonNull CompletableSource... sources) {
* {@code concat} does not operate by default on a particular {@link Scheduler}.
*
* @param sources the sources to concatenate
- * @return the {@code Completable} instance which completes only when all sources complete
+ * @return the new {@code Completable} instance
* @throws NullPointerException if {@code sources} is {@code null}
*/
@CheckReturnValue
@@ -234,7 +234,7 @@ public static Completable concat(@NonNull Iterable<@NonNull ? extends Completabl
* {@code concat} does not operate by default on a particular {@link Scheduler}.
*
* @param sources the sources to concatenate
- * @return the {@code Completable} instance which completes only when all sources complete
+ * @return the new {@code Completable} instance
* @throws NullPointerException if {@code sources} is {@code null}
*/
@CheckReturnValue
@@ -258,7 +258,7 @@ public static Completable concat(@NonNull Publisher<@NonNull ? extends Completab
*
* @param sources the sources to concatenate
* @param prefetch the number of sources to prefetch from the sources
- * @return the {@code Completable} instance which completes only when all sources complete
+ * @return the new {@code Completable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException if {@code prefetch} is non-positive
*/
@@ -334,7 +334,7 @@ public static Completable create(@NonNull CompletableOnSubscribe source) {
*
* @param source the callback which will receive the {@link CompletableObserver} instances
* when the {@code Completable} is subscribed to.
- * @return the created {@code Completable} instance
+ * @return the new {@code Completable} instance
* @throws NullPointerException if {@code source} is {@code null}
* @throws IllegalArgumentException if {@code source} is a {@code Completable}
*/
@@ -358,7 +358,7 @@ public static Completable unsafeCreate(@NonNull CompletableSource source) {
* {@code defer} does not operate by default on a particular {@link Scheduler}.
*
* @param completableSupplier the supplier that returns the {@code Completable} that will be subscribed to.
- * @return the {@code Completable} instance
+ * @return the new {@code Completable} instance
* @throws NullPointerException if {@code completableSupplier} is {@code null}
*/
@CheckReturnValue
@@ -1008,7 +1008,7 @@ public static Completable timer(long delay, @NonNull TimeUnit unit, @NonNull Sch
/**
* Creates a {@link NullPointerException} instance and sets the given {@link Throwable} as its initial cause.
* @param ex the {@code Throwable} instance to use as cause, not {@code null} (not verified)
- * @return the created {@code NullPointerException}
+ * @return the new {@code NullPointerException}
*/
private static NullPointerException toNpe(Throwable ex) {
NullPointerException npe = new NullPointerException("Actually not, but can't pass out an exception otherwise...");
@@ -1096,7 +1096,7 @@ public static Completable using(
* {@code wrap} does not operate by default on a particular {@link Scheduler}.
*
* @param source the source to wrap
- * @return the source or its wrapper {@code Completable}
+ * @return the new wrapped or cast {@code Completable} instance
* @throws NullPointerException if {@code source} is {@code null}
*/
@CheckReturnValue
@@ -1344,7 +1344,7 @@ public final Completable cache() {
* {@code compose} does not operate by default on a particular {@link Scheduler}.
*
* @param transformer the transformer function, not {@code null}
- * @return a {@code Completable} wrapping the {@code CompletableSource} returned by the function via {@link #wrap(CompletableSource)}
+ * @return the new {@code Completable} instance
* @throws NullPointerException if {@code transformer} is {@code null}
*/
@CheckReturnValue
@@ -1461,7 +1461,7 @@ public final Completable delay(long delay, @NonNull TimeUnit unit, @NonNull Sche
*
* @param delay the time to delay the subscription
* @param unit the time unit of {@code delay}
- * @return a {@code Completable} that delays the subscription to the upstream by the given amount
+ * @return the new {@code Completable} instance
* @throws NullPointerException if {@code unit} is {@code null}
* @since 3.0.0
* @see ReactiveX operators documentation: Delay
@@ -1486,8 +1486,7 @@ public final Completable delaySubscription(long delay, @NonNull TimeUnit unit) {
* @param delay the time to delay the subscription
* @param unit the time unit of {@code delay}
* @param scheduler the {@code Scheduler} on which the waiting and subscription will happen
- * @return a {@code Completable} that delays the subscription to the upstream by a given
- * amount of time, waiting and subscribing on the given {@code Scheduler}
+ * @return the new {@code Completable} instance
* @throws NullPointerException if {@code unit} or {@code scheduler} is {@code null}
* @since 3.0.0
* @see ReactiveX operators documentation: Delay
@@ -1998,8 +1997,7 @@ public final Completable onErrorResumeNext(@NonNull Function{@code onTerminateDetach} does not operate by default on a particular {@link Scheduler}.
*
* History: 2.1.5 - experimental
- * @return a {@code Completable} which {@code null}s out references to the upstream producer and downstream {@code CompletableObserver} if
- * the sequence is terminated or downstream calls {@code dispose()}
+ * @return the new {@code Completable} instance
* @since 2.2
*/
@CheckReturnValue
@@ -2336,7 +2334,7 @@ public final Completable hide() {
*
Scheduler:
* {@code subscribe} does not operate by default on a particular {@link Scheduler}.
*
- * @return the {@code Disposable} that allows disposing the subscription
+ * @return the new {@code Disposable} that can be used for disposing the subscription at any time
*/
@SchedulerSupport(SchedulerSupport.NONE)
@NonNull
@@ -2420,7 +2418,7 @@ public final void subscribe(@NonNull CompletableObserver observer) {
*
* @param onComplete the {@link Action} that is called if the {@code Completable} completes normally
* @param onError the {@link Consumer} that is called if this {@code Completable} emits an error
- * @return the {@link Disposable} that can be used for disposing the subscription asynchronously
+ * @return the new {@link Disposable} that can be used for disposing the subscription at any time
* @throws NullPointerException if {@code onComplete} or {@code onError} is {@code null}
*/
@CheckReturnValue
@@ -2449,7 +2447,7 @@ public final Disposable subscribe(@NonNull Action onComplete, @NonNull Consumer<
* {@code subscribe} does not operate by default on a particular {@link Scheduler}.
*
* @param onComplete the {@code Action} called when this {@code Completable} completes normally
- * @return the {@link Disposable} that allows disposing the subscription
+ * @return the new {@link Disposable} that can be used for disposing the subscription at any time
* @throws NullPointerException if {@code onComplete} is {@code null}
*/
@CheckReturnValue
@@ -2691,8 +2689,7 @@ public final Flowable toFlowable() {
*
*
* @param the value type
- * @return a {@code Maybe} that only calls {@code onComplete} or {@code onError}, based on which one is
- * called by the current {@code Completable}.
+ * @return the new {@code Maybe} instance
*/
@CheckReturnValue
@SuppressWarnings("unchecked")
diff --git a/src/main/java/io/reactivex/rxjava3/core/Flowable.java b/src/main/java/io/reactivex/rxjava3/core/Flowable.java
index c1f4338cd2..54bc24fca0 100644
--- a/src/main/java/io/reactivex/rxjava3/core/Flowable.java
+++ b/src/main/java/io/reactivex/rxjava3/core/Flowable.java
@@ -174,8 +174,7 @@ public abstract class Flowable<@NonNull T> implements Publisher {
* @param sources
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Amb
*/
@@ -205,8 +204,7 @@ public static Flowable amb(@NonNull Iterable<@NonNull ? extends Publisher
* @param sources
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Amb
*/
@@ -271,8 +269,7 @@ public static int bufferSize() {
* the collection of source {@code Publisher}s
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} or {@code combiner} is {@code null}
* @see ReactiveX operators documentation: CombineLatest
*/
@@ -319,8 +316,7 @@ public static int bufferSize() {
* 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 {@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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} or {@code combiner} is {@code null}
* @throws IllegalArgumentException if {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: CombineLatest
@@ -372,8 +368,7 @@ public static Flowable combineLatestArray(@NonNull Publisher<@NonNull
* the collection of source {@code Publisher}s
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} or {@code combiner} is {@code null}
* @see ReactiveX operators documentation: CombineLatest
*/
@@ -421,8 +416,7 @@ public static Flowable combineLatestArray(@NonNull Publisher<@NonNull
* 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 {@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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} or {@code combiner} is {@code null}
* @throws IllegalArgumentException if {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: CombineLatest
@@ -472,8 +466,7 @@ public static Flowable combineLatest(@NonNull Iterable<@NonNull ? exte
* the collection of source {@code Publisher}s
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} or {@code combiner} is {@code null}
* @see ReactiveX operators documentation: CombineLatest
*/
@@ -522,8 +515,7 @@ public static Flowable combineLatest(@NonNull Iterable<@NonNull ? exte
* 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 {@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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} or {@code combiner} is {@code null}
* @throws IllegalArgumentException if {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: CombineLatest
@@ -577,8 +569,7 @@ public static Flowable combineLatest(@NonNull Iterable<@NonNull ? exte
* the collection of source {@code Publisher}s
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} or {@code combiner} is {@code null}
* @see ReactiveX operators documentation: CombineLatest
*/
@@ -627,8 +618,7 @@ public static Flowable combineLatest(@NonNull Iterable<@NonNull ? exte
* 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 {@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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} or {@code combiner} is {@code null}
* @throws IllegalArgumentException if {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: CombineLatest
@@ -673,8 +663,7 @@ public static Flowable combineLatestDelayError(@NonNull Iterable<@NonN
* the second source {@code Publisher}
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2} or {@code combiner} is {@code null}
* @see ReactiveX operators documentation: CombineLatest
*/
@@ -723,8 +712,7 @@ public static Flowable combineLatest(
* the third source {@code Publisher}
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3} or {@code combiner} is {@code null}
* @see ReactiveX operators documentation: CombineLatest
*/
@@ -778,8 +766,7 @@ public static Flowable combineLatest(
* the fourth source {@code Publisher}
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4} or {@code combiner} is {@code null}
* @see ReactiveX operators documentation: CombineLatest
@@ -838,8 +825,7 @@ public static Flowable combineLatest(
* the fifth source {@code Publisher}
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4}, {@code source5} or {@code combiner} is {@code null}
* @see ReactiveX operators documentation: CombineLatest
@@ -903,8 +889,7 @@ public static Flowable combineLatest(
* the sixth source {@code Publisher}
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4}, {@code source5}, {@code source6} or {@code combiner} is {@code null}
* @see ReactiveX operators documentation: CombineLatest
@@ -972,8 +957,7 @@ public static Flowable combineLatest(
* the seventh source {@code Publisher}
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4}, {@code source5}, {@code source6},
* {@code source7} or {@code combiner} is {@code null}
@@ -1047,8 +1031,7 @@ public static Flowable combineLatest(
* the eighth source {@code Publisher}
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4}, {@code source5}, {@code source6},
* {@code source7}, {@code source8} or {@code combiner} is {@code null}
@@ -1126,8 +1109,7 @@ public static Flowable combineLatest(
* the ninth source {@code Publisher}
* @param combiner
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4}, {@code source5}, {@code source6},
* {@code source7}, {@code source8}, {@code source9}
@@ -1207,8 +1189,7 @@ public static Flowable concat(@NonNull Iterable<@NonNull ? extends Publis
* @param the common element base type
* @param sources
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Concat
*/
@@ -1240,8 +1221,7 @@ public static Flowable concat(@NonNull Publisher<@NonNull ? extends Publi
* a {@code Publisher} that emits {@code Publisher}s
* @param prefetch
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException if {@code prefetch} is non-positive
* @see ReactiveX operators documentation: Concat
@@ -1275,8 +1255,7 @@ public static Flowable concat(@NonNull Publisher<@NonNull ? extends Publi
* a {@code Publisher} to be concatenated
* @param source2
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1} or {@code source2} is {@code null}
* @see ReactiveX operators documentation: Concat
*/
@@ -1312,8 +1291,7 @@ public static Flowable concat(@NonNull Publisher<@NonNull ? extends T> so
* a {@code Publisher} to be concatenated
* @param source3
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2} or {@code source3} is {@code null}
* @see ReactiveX operators documentation: Concat
*/
@@ -1354,8 +1332,7 @@ public static Flowable concat(
* a {@code Publisher} to be concatenated
* @param source4
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3} or {@code source4} is {@code null}
* @see ReactiveX operators documentation: Concat
*/
@@ -1884,8 +1861,7 @@ public static Flowable create(@NonNull FlowableOnSubscribe source, @No
* resulting {@code Flowable}
* @param
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code supplier} is {@code null}
* @see ReactiveX operators documentation: Defer
*/
@@ -1912,8 +1888,7 @@ public static Flowable defer(@NonNull Supplier
* 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
+ * @return the shared {@code Flowable} instance
* @see ReactiveX operators documentation: Empty
*/
@CheckReturnValue
@@ -1941,8 +1916,7 @@ public static Flowable empty() {
* a {@link Supplier} factory to return a {@link Throwable} for each individual {@code Subscriber}
* @param
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code supplier} is {@code null}
* @see ReactiveX operators documentation: Throw
*/
@@ -1971,8 +1945,7 @@ public static Flowable error(@NonNull Supplier suppl
* the particular {@link Throwable} to pass to {@link Subscriber#onError onError}
* @param
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code throwable} is {@code null}
* @see ReactiveX operators documentation: Throw
*/
@@ -2001,7 +1974,7 @@ public static Flowable error(@NonNull Throwable throwable) {
* the array of elements
* @param
* the type of items in the array and the type of items to be emitted by the resulting {@code Flowable}
- * @return a {@code Flowable} that emits each item in the source array
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code items} is {@code null}
* @see ReactiveX operators documentation: From
*/
@@ -2048,7 +2021,7 @@ public static Flowable error(@NonNull Throwable throwable) {
* function only when a {@code Subscriber} subscribes to the {@code Publisher} that {@code fromCallable} returns
* @param
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code callable} is {@code null}
* @see #defer(Supplier)
* @see #fromSupplier(Supplier)
@@ -2091,7 +2064,7 @@ public static Flowable error(@NonNull Throwable throwable) {
* @param
* the type of object that the {@code Future} returns, and also the type of item to be emitted by
* the resulting {@code Flowable}
- * @return a {@code Flowable} that emits the item from the source {@code Future}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code future} is {@code null}
* @see ReactiveX operators documentation: From
* @see #fromCompletionStage(CompletionStage)
@@ -2137,7 +2110,7 @@ public static Flowable error(@NonNull Throwable throwable) {
* @param
* the type of object that the {@code Future} returns, and also the type of item to be emitted by
* the resulting {@code Flowable}
- * @return a {@code Flowable} that emits the item from the source {@code Future}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code future} or {@code unit} is {@code null}
* @see ReactiveX operators documentation: From
* @see #fromCompletionStage(CompletionStage)
@@ -2169,7 +2142,7 @@ public static Flowable error(@NonNull Throwable throwable) {
* @param
* the type of items in the {@code Iterable} sequence and the type of items to be emitted by the
* resulting {@code Flowable}
- * @return a {@code Flowable} that emits each item in the source {@code Iterable} sequence
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source} is {@code null}
* @see ReactiveX operators documentation: From
* @see #fromStream(Stream)
@@ -2251,7 +2224,7 @@ public static Flowable fromPublisher(@NonNull Publisher<@NonNull ? extend
* function only when a {@code Subscriber} subscribes to the {@code Publisher} that {@code fromSupplier} returns
* @param
* 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
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code supplier} is {@code null}
* @see #defer(Supplier)
* @see #fromCallable(Callable)
@@ -2460,8 +2433,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 {@code Flowable} that emits a 0L after the {@code initialDelay} and ever-increasing numbers after
- * each {@code period} of time thereafter
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} is {@code null}
* @see ReactiveX operators documentation: Interval
* @since 1.0.12
@@ -2496,8 +2468,7 @@ public static Flowable interval(long initialDelay, long period, @NonNull T
* the time unit for both {@code initialDelay} and {@code period}
* @param 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}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} or {@code scheduler} is {@code null}
* @see ReactiveX operators documentation: Interval
* @since 1.0.12
@@ -2528,7 +2499,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 {@code Flowable} that emits a sequential number each time interval
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} is {@code null}
* @see ReactiveX operators documentation: Interval
*/
@@ -2560,7 +2531,7 @@ public static Flowable interval(long period, @NonNull TimeUnit unit) {
* time units to use for the interval size
* @param scheduler
* the {@code Scheduler} to use for scheduling the items
- * @return a {@code Flowable} that emits a sequential number each time interval
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} or {@code scheduler} is {@code null}
* @see ReactiveX operators documentation: Interval
*/
@@ -2668,7 +2639,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* the item to emit
* @param
* the type of that item
- * @return a {@code Flowable} that emits {@code value} as a single item and then completes
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code item} is {@code null}
* @see ReactiveX operators documentation: Just
* @see #just(Object, Object)
@@ -2702,7 +2673,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* second item
* @param
* the type of these items
- * @return a {@code Flowable} that emits each item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code item1} or {@code item2} is {@code null}
* @see ReactiveX operators documentation: Just
*/
@@ -2736,7 +2707,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* third item
* @param
* the type of these items
- * @return a {@code Flowable} that emits each item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code item1}, {@code item2} or {@code item3} is {@code null}
* @see ReactiveX operators documentation: Just
*/
@@ -2773,7 +2744,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* fourth item
* @param
* the type of these items
- * @return a {@code Flowable} that emits each item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code item1}, {@code item2}, {@code item3},
* or {@code item4} is {@code null}
* @see ReactiveX operators documentation: Just
@@ -2814,7 +2785,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* fifth item
* @param
* the type of these items
- * @return a {@code Flowable} that emits each item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code item1}, {@code item2}, {@code item3},
* {@code item4} or {@code item5} is {@code null}
* @see ReactiveX operators documentation: Just
@@ -2858,7 +2829,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* sixth item
* @param
* the type of these items
- * @return a {@code Flowable} that emits each item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code item1}, {@code item2}, {@code item3},
* {@code item4}, {@code item5} or {@code item6} is {@code null}
* @see ReactiveX operators documentation: Just
@@ -2905,7 +2876,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* seventh item
* @param
* the type of these items
- * @return a {@code Flowable} that emits each item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code item1}, {@code item2}, {@code item3},
* {@code item4}, {@code item5}, {@code item6}
* or {@code item7} is {@code null}
@@ -2956,7 +2927,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* eighth item
* @param
* the type of these items
- * @return a {@code Flowable} that emits each item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code item1}, {@code item2}, {@code item3},
* {@code item4}, {@code item5}, {@code item6},
* {@code item7} or {@code item8} is {@code null}
@@ -3010,7 +2981,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* ninth item
* @param
* the type of these items
- * @return a {@code Flowable} that emits each item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code item1}, {@code item2}, {@code item3},
* {@code item4}, {@code item5}, {@code item6},
* {@code item7}, {@code item8} or {@code item9} is {@code null}
@@ -3067,7 +3038,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* tenth item
* @param
* the type of these items
- * @return a {@code Flowable} that emits each item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code item1}, {@code item2}, {@code item3},
* {@code item4}, {@code item5}, {@code item6},
* {@code item7}, {@code item8}, {@code item9},
@@ -3129,8 +3100,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* the maximum number of {@code Publisher}s that may be subscribed to concurrently
* @param bufferSize
* the number of items to prefetch from each inner {@code Publisher}
- * @return a {@code Flowable} that emits items that are the result of flattening the items emitted by the
- * {@code Publisher}s in the {@code Iterable}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException
* if {@code maxConcurrency} or {@code bufferSize} is non-positive
@@ -3182,8 +3152,7 @@ public static Flowable merge(@NonNull Iterable<@NonNull ? extends Publish
* the maximum number of {@code Publisher}s that may be subscribed to concurrently
* @param bufferSize
* the number of items to prefetch from each inner {@code Publisher}
- * @return a {@code Flowable} that emits items that are the result of flattening the items emitted by the
- * {@code Publisher}s
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException
* if {@code maxConcurrency} or {@code bufferSize} is non-positive
@@ -3231,8 +3200,7 @@ public static Flowable mergeArray(int maxConcurrency, int bufferSize, @No
* @param the common element base type
* @param sources
* the {@code Iterable} of {@code Publisher}s
- * @return a {@code Flowable} that emits items that are the result of flattening the items emitted by the
- * {@code Publisher}s in the {@code Iterable}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Merge
* @see #mergeDelayError(Iterable)
@@ -3280,8 +3248,7 @@ public static Flowable merge(@NonNull Iterable<@NonNull ? extends Publish
* the {@code Iterable} of {@code Publisher}s
* @param maxConcurrency
* the maximum number of {@code Publisher}s that may be subscribed to concurrently
- * @return a {@code Flowable} that emits items that are the result of flattening the items emitted by the
- * {@code Publisher}s in the {@code Iterable}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException
* if {@code maxConcurrency} is less than or equal to 0
@@ -3330,8 +3297,7 @@ public static Flowable merge(@NonNull Iterable<@NonNull ? extends Publish
* @param the common element base type
* @param sources
* a {@code Publisher} that emits {@code Publisher}s
- * @return a {@code Flowable} that emits items that are the result of flattening the {@code Publisher}s emitted by the
- * {@code source} {@code Publisher}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Merge
* @see #mergeDelayError(Publisher)
@@ -3379,8 +3345,7 @@ public static Flowable merge(@NonNull Publisher<@NonNull ? extends Publis
* a {@code Publisher} that emits {@code Publisher}s
* @param maxConcurrency
* the maximum number of {@code Publisher}s that may be subscribed to concurrently
- * @return a {@code Flowable} that emits items that are the result of flattening the {@code Publisher}s emitted by the
- * {@code source} {@code Publisher}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException
* if {@code maxConcurrency} is less than or equal to 0
@@ -3428,7 +3393,7 @@ public static Flowable merge(@NonNull Publisher<@NonNull ? extends Publis
* @param the common element base type
* @param sources
* the array of {@code Publisher}s
- * @return a {@code Flowable} that emits all of the items emitted by the {@code Publisher}s
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Merge
* @see #mergeArrayDelayError(Publisher...)
@@ -3476,7 +3441,7 @@ public static Flowable mergeArray(@NonNull Publisher<@NonNull ? extends T
* a {@code Publisher} to be merged
* @param source2
* a {@code Publisher} to be merged
- * @return a {@code Flowable} that emits all of the items emitted by the source {@code Publisher}s
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1} or {@code source2} is {@code null}
* @see ReactiveX operators documentation: Merge
* @see #mergeDelayError(Publisher, Publisher)
@@ -3527,7 +3492,7 @@ public static Flowable merge(@NonNull Publisher<@NonNull ? extends T> sou
* a {@code Publisher} to be merged
* @param source3
* a {@code Publisher} to be merged
- * @return a {@code Flowable} that emits all of the items emitted by the source {@code Publisher}s
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2} or {@code source3} is {@code null}
* @see ReactiveX operators documentation: Merge
* @see #mergeDelayError(Publisher, Publisher, Publisher)
@@ -3581,7 +3546,7 @@ public static Flowable merge(@NonNull Publisher<@NonNull ? extends T> sou
* a {@code Publisher} to be merged
* @param source4
* a {@code Publisher} to be merged
- * @return a {@code Flowable} that emits all of the items emitted by the source {@code Publisher}s
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3} or {@code source4} is {@code null}
* @see ReactiveX operators documentation: Merge
* @see #mergeDelayError(Publisher, Publisher, Publisher, Publisher)
@@ -3625,8 +3590,7 @@ public static Flowable merge(
* @param the common element base type
* @param sources
* the {@code Iterable} of {@code Publisher}s
- * @return a {@code Flowable} that emits items that are the result of flattening the items emitted by the
- * {@code Publisher}s in the {@code Iterable}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@@ -3667,8 +3631,7 @@ public static Flowable mergeDelayError(@NonNull Iterable<@NonNull ? exten
* the maximum number of {@code Publisher}s that may be subscribed to concurrently
* @param bufferSize
* the number of items to prefetch from each inner {@code Publisher}
- * @return a {@code Flowable} that emits items that are the result of flattening the items emitted by the
- * {@code Publisher}s in the {@code Iterable}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException if {@code maxConcurrency} or {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: Merge
@@ -3710,8 +3673,7 @@ public static Flowable mergeDelayError(@NonNull Iterable<@NonNull ? exten
* the maximum number of {@code Publisher}s that may be subscribed to concurrently
* @param bufferSize
* the number of items to prefetch from each inner {@code Publisher}
- * @return a {@code Flowable} that emits items that are the result of flattening the items emitted by the
- * {@code Publisher}s
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException if {@code maxConcurrency} or {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: Merge
@@ -3752,8 +3714,7 @@ public static Flowable mergeArrayDelayError(int maxConcurrency, int buffe
* the {@code Iterable} of {@code Publisher}s
* @param maxConcurrency
* the maximum number of {@code Publisher}s that may be subscribed to concurrently
- * @return a {@code Flowable} that emits items that are the result of flattening the items emitted by the
- * {@code Publisher}s in the {@code Iterable}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException if {@code maxConcurrency} is non-positive
* @see ReactiveX operators documentation: Merge
@@ -3792,8 +3753,7 @@ public static Flowable mergeDelayError(@NonNull Iterable<@NonNull ? exten
* @param the common element base type
* @param sources
* a {@code Publisher} that emits {@code Publisher}s
- * @return a {@code Flowable} that emits all of the items emitted by the {@code Publisher}s emitted by the
- * {@code source} {@code Publisher}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@@ -3832,8 +3792,7 @@ public static Flowable mergeDelayError(@NonNull Publisher<@NonNull ? exte
* a {@code Publisher} that emits {@code Publisher}s
* @param maxConcurrency
* the maximum number of {@code Publisher}s that may be subscribed to concurrently
- * @return a {@code Flowable} that emits all of the items emitted by the {@code Publisher}s emitted by the
- * {@code source} {@code Publisher}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException if {@code maxConcurrency} is non-positive
* @see ReactiveX operators documentation: Merge
@@ -3872,8 +3831,7 @@ public static Flowable mergeDelayError(@NonNull Publisher<@NonNull ? exte
* @param the common element base type
* @param sources
* the array of {@code Publisher}s
- * @return a {@code Flowable} that emits items that are the result of flattening the items emitted by the
- * {@code Publisher}s
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@@ -3913,7 +3871,7 @@ public static Flowable mergeArrayDelayError(@NonNull Publisher<@NonNull ?
* a {@code Publisher} to be merged
* @param source2
* a {@code Publisher} to be merged
- * @return a {@code Flowable} that emits all of the items that are emitted by the two source {@code Publisher}s
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1} or {@code source2} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@@ -3957,7 +3915,7 @@ public static Flowable mergeDelayError(@NonNull Publisher<@NonNull ? exte
* a {@code Publisher} to be merged
* @param source3
* a {@code Publisher} to be merged
- * @return a {@code Flowable} that emits all of the items that are emitted by the source {@code Publisher}s
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2} or {@code source3} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@@ -4004,7 +3962,7 @@ public static Flowable mergeDelayError(@NonNull Publisher<@NonNull ? exte
* a {@code Publisher} to be merged
* @param source4
* a {@code Publisher} to be merged
- * @return a {@code Flowable} that emits all of the items that are emitted by the source {@code Publisher}s
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3} or {@code source4} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@@ -4038,7 +3996,7 @@ public static Flowable mergeDelayError(
*
* @param
* the type of items (not) emitted by the {@code Publisher}
- * @return a {@code Flowable} that never emits any items or sends any notifications to a {@code Subscriber}
+ * @return the shared {@code Flowable} instance
* @see ReactiveX operators documentation: Never
*/
@CheckReturnValue
@@ -4065,7 +4023,7 @@ public static Flowable never() {
* the value of the first {@code Integer} in the sequence
* @param count
* the number of sequential {@code Integer}s to generate
- * @return a {@code Flowable} that emits a range of sequential {@code Integer}s
+ * @return the new {@code Flowable} instance
* @throws IllegalArgumentException
* if {@code count} is less than zero, or if {@code start} + {@code count} − 1 exceeds
* {@link Integer#MAX_VALUE}
@@ -4106,7 +4064,7 @@ public static Flowable range(int start, int count) {
* the value of the first {@code Long} in the sequence
* @param count
* the number of sequential {@code Long}s to generate
- * @return a {@code Flowable} that emits a range of sequential {@code Long}s
+ * @return the new {@code Flowable} instance
* @throws IllegalArgumentException
* if {@code count} is less than zero, or if {@code start} + {@code count} − 1 exceeds
* {@link Long#MAX_VALUE}
@@ -4156,7 +4114,7 @@ public static Flowable rangeLong(long start, long count) {
* the second {@code Publisher} to compare
* @param
* the type of items emitted by each {@code Publisher}
- * @return a {@code Single} that emits a {@code Boolean} value that indicates whether the two sequences are the same
+ * @return the new {@code Single} instance
* @throws NullPointerException if {@code source1} or {@code source2} is {@code null}
* @see ReactiveX operators documentation: SequenceEqual
*/
@@ -4190,8 +4148,7 @@ public static Single sequenceEqual(@NonNull Publisher<@NonNull ? ex
* a function used to compare items emitted by each {@code Publisher}
* @param
* the type of items emitted by each {@code Publisher}
- * @return a {@code Single} that emits a {@code Boolean} value that indicates whether the two {@code Publisher} sequences
- * are the same according to the specified function
+ * @return the new {@code Single} instance
* @throws NullPointerException if {@code source1}, {@code source2} or {@code isEqual} is {@code null}
* @see ReactiveX operators documentation: SequenceEqual
*/
@@ -4228,8 +4185,7 @@ public static Single sequenceEqual(@NonNull Publisher<@NonNull ? ex
* the number of items to prefetch from the first and second source {@code Publisher}
* @param
* the type of items emitted by each {@code Publisher}
- * @return a {@code Single} that emits a {@code Boolean} value that indicates whether the two {@code Publisher} sequences
- * are the same according to the specified function
+ * @return the new {@code Single} instance
* @throws NullPointerException if {@code source1}, {@code source2} or {@code isEqual} is {@code null}
* @throws IllegalArgumentException if {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: SequenceEqual
@@ -4268,7 +4224,7 @@ public static Single sequenceEqual(@NonNull Publisher<@NonNull ? ex
* the number of items to prefetch from the first and second source {@code Publisher}
* @param
* the type of items emitted by each {@code Publisher}
- * @return a {@code Single} that emits a {@code Boolean} value that indicates whether the two sequences are the same
+ * @return the new {@code Single} instance
* @throws NullPointerException if {@code source1} or {@code source2} is {@code null}
* @throws IllegalArgumentException if {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: SequenceEqual
@@ -4309,8 +4265,7 @@ public static Single sequenceEqual(@NonNull Publisher<@NonNull ? ex
* the source {@code Publisher} that emits {@code Publisher}s
* @param bufferSize
* the number of items to prefetch from the inner {@code Publisher}s
- * @return a {@code Flowable} that emits the items emitted by the {@code Publisher} most recently emitted by the source
- * {@code Publisher}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException if {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: Switch
@@ -4350,8 +4305,7 @@ public static Flowable switchOnNext(@NonNull Publisher<@NonNull ? extends
* @param the item type
* @param sources
* the source {@code Publisher} that emits {@code Publisher}s
- * @return a {@code Flowable} that emits the items emitted by the {@code Publisher} most recently emitted by the source
- * {@code Publisher}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Switch
*/
@@ -4391,8 +4345,7 @@ public static Flowable switchOnNext(@NonNull Publisher<@NonNull ? extends
* @param the item type
* @param sources
* the source {@code Publisher} that emits {@code Publisher}s
- * @return a {@code Flowable} that emits the items emitted by the {@code Publisher} most recently emitted by the source
- * {@code Publisher}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Switch
* @since 2.0
@@ -4434,8 +4387,7 @@ public static Flowable switchOnNextDelayError(@NonNull Publisher<@NonNull
* the source {@code Publisher} that emits {@code Publisher}s
* @param prefetch
* the number of items to prefetch from the inner {@code Publisher}s
- * @return a {@code Flowable} that emits the items emitted by the {@code Publisher} most recently emitted by the source
- * {@code Publisher}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} is {@code null}
* @throws IllegalArgumentException if {@code prefetch} is non-positive
* @see ReactiveX operators documentation: Switch
@@ -4465,7 +4417,7 @@ public static Flowable switchOnNextDelayError(@NonNull Publisher<@NonNull
* the initial delay before emitting a single {@code 0L}
* @param unit
* time units to use for {@code delay}
- * @return a {@code Flowable} that emits {@code 0L} after a specified delay, and then completes
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} is {@code null}
* @see ReactiveX operators documentation: Timer
*/
@@ -4496,8 +4448,7 @@ public static Flowable timer(long delay, @NonNull TimeUnit unit) {
* time units to use for {@code delay}
* @param scheduler
* the {@code Scheduler} to use for scheduling the item
- * @return a {@code Flowable} that emits {@code 0L} after a specified delay, on a specified {@code Scheduler}, and then
- * completes
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} or {@code scheduler} is {@code null}
* @see ReactiveX operators documentation: Timer
*/
@@ -4565,7 +4516,7 @@ public static Flowable unsafeCreate(@NonNull Publisher onSubscribe) {
* the factory function to create a {@code Publisher}
* @param resourceDisposer
* the function that will dispose of the resource
- * @return the {@code Flowable} whose lifetime controls the lifetime of the dependent resource object
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code resourceSupplier}, {@code sourceSupplier} or {@code resourceDisposer} is {@code null}
* @see ReactiveX operators documentation: Using
*/
@@ -4607,7 +4558,7 @@ public static Flowable using(
* or just before the emission of a terminal event ({@code onComplete} or {@code onError}).
* If {@code false} the resource disposal will happen either on a {@code cancel()} call after the upstream is disposed
* or just after the emission of a terminal event ({@code onComplete} or {@code onError}).
- * @return the {@code Flowable} whose lifetime controls the lifetime of the dependent resource object
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code resourceSupplier}, {@code sourceSupplier} or {@code resourceDisposer} is {@code null}
* @see ReactiveX operators documentation: Using
* @since 2.0
@@ -4668,7 +4619,7 @@ public static Flowable using(
* @param zipper
* a function that, when applied to an item emitted by each of the source {@code Publisher}s, results in
* an item that will be emitted by the resulting {@code Flowable}
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
*/
@@ -4728,7 +4679,7 @@ public static Flowable zip(@NonNull Iterable<@NonNull ? extends Publis
* the number of elements to prefetch from each source {@code Publisher}
* @param the common source value type
* @param the zipped result type
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} or {@code zipper} is {@code null}
* @throws IllegalArgumentException if {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: Zip
@@ -4791,7 +4742,7 @@ public static Flowable zip(@NonNull Iterable<@NonNull ? extends Publis
* @param zipper
* a function that, when applied to an item emitted by each of the source {@code Publisher}s, results
* in an item that will be emitted by the resulting {@code Flowable}
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
*/
@@ -4854,7 +4805,7 @@ public static Flowable zip(
* a function that, when applied to an item emitted by each of the source {@code Publisher}s, results
* in an item that will be emitted by the resulting {@code Flowable}
* @param delayError delay errors from any of the source {@code Publisher}s till the other terminates
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
*/
@@ -4918,7 +4869,7 @@ public static Flowable zip(
* in an item that will be emitted by the resulting {@code Flowable}
* @param delayError delay errors from any of the source {@code Publisher}s till the other terminates
* @param bufferSize the number of elements to prefetch from each source {@code Publisher}
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2} or {@code zipper} is {@code null}
* @throws IllegalArgumentException if {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: Zip
@@ -4985,7 +4936,7 @@ public static Flowable zip(
* @param zipper
* a function that, when applied to an item emitted by each of the source {@code Publisher}s, results in
* an item that will be emitted by the resulting {@code Flowable}
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
*/
@@ -5055,7 +5006,7 @@ public static Flowable zip(
* @param zipper
* a function that, when applied to an item emitted by each of the source {@code Publisher}s, results in
* an item that will be emitted by the resulting {@code Flowable}
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
@@ -5131,7 +5082,7 @@ public static Flowable zip(
* @param zipper
* a function that, when applied to an item emitted by each of the source {@code Publisher}s, results in
* an item that will be emitted by the resulting {@code Flowable}
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4}, {@code source5} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
@@ -5210,7 +5161,7 @@ public static Flowable zip(
* @param zipper
* a function that, when applied to an item emitted by each of the source {@code Publisher}s, results in
* an item that will be emitted by the resulting {@code Flowable}
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4}, {@code source5}, {@code source6}
* or {@code zipper} is {@code null}
@@ -5294,7 +5245,7 @@ public static Flowable zip(
* @param zipper
* a function that, when applied to an item emitted by each of the source {@code Publisher}s, results in
* an item that will be emitted by the resulting {@code Flowable}
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4}, {@code source5}, {@code source6},
* {@code source7} or {@code zipper} is {@code null}
@@ -5383,7 +5334,7 @@ public static Flowable zip(
* @param zipper
* a function that, when applied to an item emitted by each of the source {@code Publisher}s, results in
* an item that will be emitted by the resulting {@code Flowable}
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4}, {@code source5}, {@code source6},
* {@code source7}, {@code source8} or {@code zipper} is {@code null}
@@ -5476,7 +5427,7 @@ public static Flowable zip(
* @param zipper
* a function that, when applied to an item emitted by each of the source {@code Publisher}s, results in
* an item that will be emitted by the resulting {@code Flowable}
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
* {@code source4}, {@code source5}, {@code source6},
* {@code source7}, {@code source8}, {@code source9}
@@ -5552,7 +5503,7 @@ public static Flowable zip(
* delay errors signaled by any of the source {@code Publisher} until all {@code Publisher}s terminate
* @param bufferSize
* the number of elements to prefetch from each source {@code Publisher}
- * @return a {@code Flowable} that emits the zipped results
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code sources} or {@code zipper} is {@code null}
* @throws IllegalArgumentException if {@code bufferSize} is non-positive
* @see ReactiveX operators documentation: Zip
@@ -5592,8 +5543,7 @@ public static Flowable zipArray(@NonNull FunctionReactiveX operators documentation: All
*/
@@ -5622,8 +5572,7 @@ public final Single all(@NonNull Predicate predicate) {
* @param other
* a {@code Publisher} competing to react first. A subscription to this provided {@code Publisher} will occur after subscribing
* to the current {@code Flowable}.
- * @return a {@code Flowable} that emits the same sequence as whichever of this or the other {@code Publisher} first
- * emitted an item or sent a termination notification
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code other} is {@code null}
* @see ReactiveX operators documentation: Amb
*/
@@ -5655,8 +5604,7 @@ public final Flowable ambWith(@NonNull Publisher<@NonNull ? extends T> other)
*
* @param predicate
* the condition to test items emitted by the current {@code Flowable}
- * @return a {@code Single} that emits a {@link Boolean} that indicates whether any item emitted by the current
- * {@code Flowable} satisfies the {@code predicate}
+ * @return the new {@code Single} instance
* @throws NullPointerException if {@code predicate} is {@code null}
* @see ReactiveX operators documentation: Contains
*/
@@ -5684,7 +5632,7 @@ public final Single any(@NonNull Predicate predicate) {
* {@link Error}s are rethrown as they are.
*
*
- * @return the first item emitted by this {@code Flowable}
+ * @return the new {@code Flowable} instance
* @throws NoSuchElementException
* if this {@code Flowable} emits no items
* @see ReactiveX documentation: First
@@ -5720,8 +5668,7 @@ public final T blockingFirst() {
*
* @param defaultItem
* a default value to return if this {@code Flowable} emits no items
- * @return the first item emitted by this {@code Flowable}, or the default value if it emits no
- * items
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code defaultItem} is {@code null}
* @see ReactiveX documentation: First
*/
@@ -5843,7 +5790,7 @@ public final void blockingForEach(@NonNull Consumer onNext, int buffe
* {@code blockingIterable} does not operate by default on a particular {@link Scheduler}.
*
*
- * @return an {@code Iterable} version of this {@code Flowable}
+ * @return the new {@code Iterable} instance
* @see ReactiveX documentation: To
*/
@CheckReturnValue
@@ -5868,7 +5815,7 @@ public final Iterable blockingIterable() {
*
*
* @param bufferSize the number of items to prefetch from the current {@code Flowable}
- * @return an {@code Iterable} version of this {@code Flowable}
+ * @return the new {@code Iterable} instance
* @throws IllegalArgumentException if {@code bufferSize} is non-positive
* @see ReactiveX documentation: To
*/
@@ -5898,7 +5845,7 @@ public final Iterable blockingIterable(int bufferSize) {
* {@link Error}s are rethrown as they are.
*
*
- * @return the last item emitted by this {@code Flowable}
+ * @return the new {@code Flowable} instance
* @throws NoSuchElementException
* if this {@code Flowable} emits no items
* @see ReactiveX documentation: Last
@@ -5936,8 +5883,7 @@ public final T blockingLast() {
*
* @param defaultItem
* a default value to return if this {@code Flowable} emits no items
- * @return the last item emitted by the {@code Flowable}, or the default value if it emits no
- * items
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code defaultItem} is {@code null}
* @see ReactiveX documentation: Last
*/
@@ -5970,7 +5916,7 @@ public final T blockingLast(@NonNull T defaultItem) {
* {@code blockingLatest} does not operate by default on a particular {@link Scheduler}.
*
*
- * @return an {@code Iterable} that always returns the latest item emitted by this {@code Flowable}
+ * @return the new {@code Iterable} instance
* @see ReactiveX documentation: First
*/
@CheckReturnValue
@@ -5997,8 +5943,7 @@ public final Iterable blockingLatest() {
* @param initialItem
* the initial item that the {@code Iterable} sequence will yield if this
* {@code Flowable} has not yet emitted an item
- * @return an {@code Iterable} that on each iteration returns the item that this {@code Flowable}
- * has most recently emitted
+ * @return the new {@code Iterable} instance
* @see ReactiveX documentation: First
*/
@CheckReturnValue
@@ -6022,8 +5967,7 @@ public final Iterable blockingMostRecent(@NonNull T initialItem) {
* {@code blockingNext} does not operate by default on a particular {@link Scheduler}.
*
*
- * @return an {@code Iterable} that blocks upon each iteration until this {@code Flowable} emits
- * a new item, whereupon the {@code Iterable} returns that item
+ * @return the new {@code Iterable} instance
* @see ReactiveX documentation: TakeLast
*/
@CheckReturnValue
@@ -6051,7 +5995,7 @@ public final Iterable blockingNext() {
* {@link Error}s are rethrown as they are.
*
*
- * @return the single item emitted by this {@code Flowable}
+ * @return the new {@code Flowable} instance
* @see ReactiveX documentation: First
*/
@CheckReturnValue
@@ -6082,8 +6026,7 @@ public final T blockingSingle() {
*
* @param defaultItem
* a default value to return if this {@code Flowable} emits no items
- * @return the single item emitted by this {@code Flowable}, or the default value if it emits no
- * items
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code defaultItem} is {@code null}
* @see ReactiveX documentation: First
*/
@@ -6114,7 +6057,7 @@ public final T blockingSingle(@NonNull T defaultItem) {
* {@code toFuture} does not operate by default on a particular {@link Scheduler}.
*
*
- * @return a {@code Future} that expects a single item to be emitted by this {@code Flowable}
+ * @return the new {@code Future} instance
* @see ReactiveX documentation: To
*/
@CheckReturnValue
@@ -6367,8 +6310,7 @@ public final void blockingSubscribe(@NonNull Subscriber<@NonNull ? super T> subs
*
* @param count
* the maximum number of items in each buffer before it should be emitted
- * @return a {@code Flowable} that emits connected, non-overlapping buffers, each containing at most
- * {@code count} items from the current {@code Flowable}
+ * @return the new {@code Flowable} instance
* @throws IllegalArgumentException if {@code count} is non-positive
* @see ReactiveX operators documentation: Buffer
*/
@@ -6403,8 +6345,7 @@ public final Flowable> buffer(int count) {
* how many items emitted by the current {@code Flowable} should be skipped before starting a new
* buffer. Note that when {@code skip} and {@code count} are equal, this is the same operation as
* {@link #buffer(int)}.
- * @return a {@code Flowable} that emits buffers for every {@code skip} item from the current {@code Flowable} and
- * containing at most {@code count} items
+ * @return the new {@code Flowable} instance
* @throws IllegalArgumentException if {@code count} or {@code skip} is non-positive
* @see ReactiveX operators documentation: Buffer
*/
@@ -6443,8 +6384,7 @@ public final Flowable> buffer(int count, int skip) {
* @param bufferSupplier
* a factory function that returns an instance of the collection subclass to be used and returned
* as the buffer
- * @return a {@code Flowable} that emits buffers for every {@code skip} item from the current {@code Flowable} and
- * containing at most {@code count} items
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code bufferSupplier} is {@code null}
* @throws IllegalArgumentException if {@code count} or {@code skip} is non-positive
* @see ReactiveX operators documentation: Buffer
@@ -6483,8 +6423,7 @@ public final > Flowable buffer(int count, int
* @param bufferSupplier
* a factory function that returns an instance of the collection subclass to be used and returned
* as the buffer
- * @return a {@code Flowable} that emits connected, non-overlapping buffers, each containing at most
- * {@code count} items from the current {@code Flowable}
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code bufferSupplier} is {@code null}
* @throws IllegalArgumentException if {@code count} is non-positive
* @see ReactiveX operators documentation: Buffer
@@ -6520,8 +6459,7 @@ public final > Flowable buffer(int count, @No
* the period of time after which a new buffer will be created
* @param unit
* the unit of time that applies to the {@code timespan} and {@code timeskip} arguments
- * @return a {@code Flowable} that emits new buffers of items emitted by the current {@code Flowable} periodically after
- * a fixed timespan has elapsed
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} is {@code null}
* @see ReactiveX operators documentation: Buffer
*/
@@ -6559,8 +6497,7 @@ public final Flowable> buffer(long timespan, long timeskip, @NonNull Tim
* the unit of time that applies to the {@code timespan} and {@code timeskip} arguments
* @param scheduler
* the {@code Scheduler} to use when determining the end and start of a buffer
- * @return a {@code Flowable} that emits new buffers of items emitted by the current {@code Flowable} periodically after
- * a fixed timespan has elapsed
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} or {@code scheduler} is {@code null}
* @see ReactiveX operators documentation: Buffer
*/
@@ -6602,8 +6539,7 @@ public final Flowable> buffer(long timespan, long timeskip, @NonNull Tim
* @param bufferSupplier
* a factory function that returns an instance of the collection subclass to be used and returned
* as the buffer
- * @return a {@code Flowable} that emits new buffers of items emitted by the current {@code Flowable} periodically after
- * a fixed timespan has elapsed
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit}, {@code scheduler} or {@code bufferSupplier} is {@code null}
* @see ReactiveX operators documentation: Buffer
*/
@@ -6641,8 +6577,7 @@ public final > Flowable buffer(long timespan,
* buffer
* @param unit
* the unit of time that applies to the {@code timespan} argument
- * @return a {@code Flowable} that emits connected, non-overlapping buffers of items emitted by the current
- * {@code Flowable} within a fixed duration
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} is {@code null}
* @see ReactiveX operators documentation: Buffer
*/
@@ -6678,9 +6613,7 @@ public final Flowable> buffer(long timespan, @NonNull TimeUnit unit) {
* the unit of time which applies to the {@code timespan} argument
* @param count
* the maximum size of each buffer before it is emitted
- * @return a {@code Flowable} that emits connected, non-overlapping buffers of items emitted by the current
- * {@code Flowable}, after a fixed duration or when the buffer reaches maximum capacity (whichever occurs
- * first)
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} is {@code null}
* @throws IllegalArgumentException if {@code count} is non-positive
* @see ReactiveX operators documentation: Buffer
@@ -6720,9 +6653,7 @@ public final Flowable> buffer(long timespan, @NonNull TimeUnit unit, int
* the {@code Scheduler} to use when determining the end and start of a buffer
* @param count
* the maximum size of each buffer before it is emitted
- * @return a {@code Flowable} that emits connected, non-overlapping buffers of items emitted by the current
- * {@code Flowable} after a fixed duration or when the buffer reaches maximum capacity (whichever occurs
- * first)
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} or {@code scheduler} is {@code null}
* @throws IllegalArgumentException if {@code count} is non-positive
* @see ReactiveX operators documentation: Buffer
@@ -6768,9 +6699,7 @@ public final Flowable> buffer(long timespan, @NonNull TimeUnit unit, @No
* as the buffer
* @param restartTimerOnMaxSize if {@code true}, the time window is restarted when the max capacity of the current buffer
* is reached
- * @return a {@code Flowable} that emits connected, non-overlapping buffers of items emitted by the current
- * {@code Flowable} after a fixed duration or when the buffer reaches maximum capacity (whichever occurs
- * first)
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit}, {@code scheduler} or {@code bufferSupplier} is {@code null}
* @throws IllegalArgumentException if {@code count} is non-positive
* @see ReactiveX operators documentation: Buffer
@@ -6815,8 +6744,7 @@ public final > Flowable buffer(
* the unit of time which applies to the {@code timespan} argument
* @param scheduler
* the {@code Scheduler} to use when determining the end and start of a buffer
- * @return a {@code Flowable} that emits connected, non-overlapping buffers of items emitted by the current
- * {@code Flowable} within a fixed duration
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code unit} or {@code scheduler} is {@code null}
* @see ReactiveX operators documentation: Buffer
*/
@@ -6851,8 +6779,7 @@ public final Flowable> buffer(long timespan, @NonNull TimeUnit unit, @No
* @param closingIndicator
* the {@link Function} that is used to produce a {@code Publisher} for every buffer created. When this
* {@code Publisher} emits an item, the associated buffer is emitted.
- * @return a {@code Flowable} that emits buffers, containing items from the current {@code Flowable}, that are created
- * and closed when the specified {@code Publisher}s emit items
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code openingIndicator} or {@code closingIndicator} is {@code null}
* @see ReactiveX operators documentation: Buffer
*/
@@ -6893,8 +6820,7 @@ public final Flowable> buffer(
* @param bufferSupplier
* a factory function that returns an instance of the collection subclass to be used and returned
* as the buffer
- * @return a {@code Flowable} that emits buffers, containing items from the current {@code Flowable}, that are created
- * and closed when the specified {@code Publisher}s emit items
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code openingIndicator}, {@code closingIndicator} or {@code bufferSupplier} is {@code null}
* @see ReactiveX operators documentation: Buffer
*/
@@ -6934,8 +6860,7 @@ public final > Flowable b
* the boundary value type (ignored)
* @param boundaryIndicator
* the boundary {@code Publisher}
- * @return a {@code Flowable} that emits buffered items from the current {@code Flowable} when the boundary {@code Publisher}
- * emits an item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code boundaryIndicator} is {@code null}
* @see #buffer(Publisher, int)
* @see ReactiveX operators documentation: Buffer
@@ -6972,8 +6897,7 @@ public final Flowable> buffer(@NonNull Publisher boundaryIndicato
* the boundary {@code Publisher}
* @param initialCapacity
* the initial capacity of each buffer chunk
- * @return a {@code Flowable} that emits buffered items from the current {@code Flowable} when the boundary {@code Publisher}
- * emits an item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code boundaryIndicator} is {@code null}
* @throws IllegalArgumentException if {@code initialCapacity} is non-positive
* @see ReactiveX operators documentation: Buffer
@@ -7014,8 +6938,7 @@ public final Flowable> buffer(@NonNull Publisher boundaryIndicato
* @param bufferSupplier
* a factory function that returns an instance of the collection subclass to be used and returned
* as the buffer
- * @return a {@code Flowable} that emits buffered items from the current {@code Flowable} when the boundary {@code Publisher}
- * emits an item
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code boundaryIndicator} or {@code bufferSupplier} is {@code null}
* @see #buffer(Publisher, int)
* @see ReactiveX operators documentation: Buffer
@@ -7077,8 +7000,7 @@ public final > Flowable buffer(@NonNull Pu
* {@code cache} does not operate by default on a particular {@link Scheduler}.
*
*
- * @return a {@code Flowable} that, when first subscribed to, caches all of its items and notifications for the
- * benefit of subsequent subscribers
+ * @return the new {@code Flowable} instance
* @see ReactiveX operators documentation: Replay
* @see #takeUntil(Predicate)
* @see #takeUntil(Publisher)
@@ -7142,8 +7064,7 @@ public final Flowable cache() {
* {@link #replay(int)} in combination with {@link ConnectableFlowable#autoConnect()} or similar.
*
* @param initialCapacity hint for number of items to cache (for optimizing underlying data structure)
- * @return a {@code Flowable} that, when first subscribed to, caches all of its items and notifications for the
- * benefit of subsequent subscribers
+ * @return the new {@code Flowable} instance
* @throws IllegalArgumentException if {@code initialCapacity} is non-positive
* @see ReactiveX operators documentation: Replay
* @see #takeUntil(Predicate)
@@ -7175,8 +7096,7 @@ public final Flowable cacheWithInitialCapacity(int initialCapacity) {
* @param clazz
* the target class type that {@code cast} will cast the items emitted by the current {@code Flowable}
* into before emitting them from the resulting {@code Flowable}
- * @return a {@code Flowable} that emits each item from the current {@code Flowable} after converting it to the
- * specified type
+ * @return the new {@code Flowable} instance
* @throws NullPointerException if {@code clazz} is {@code null}
* @see ReactiveX operators documentation: Map
*/
@@ -7214,8 +7134,7 @@ public final Flowable cast(@NonNull Class