diff --git a/src/main/java/io/reactivex/rxjava3/core/Maybe.java b/src/main/java/io/reactivex/rxjava3/core/Maybe.java
index 84a088d5c7..e8e01a15c7 100644
--- a/src/main/java/io/reactivex/rxjava3/core/Maybe.java
+++ b/src/main/java/io/reactivex/rxjava3/core/Maybe.java
@@ -21,7 +21,7 @@
import io.reactivex.rxjava3.annotations.*;
import io.reactivex.rxjava3.disposables.Disposable;
-import io.reactivex.rxjava3.exceptions.Exceptions;
+import io.reactivex.rxjava3.exceptions.*;
import io.reactivex.rxjava3.functions.*;
import io.reactivex.rxjava3.internal.functions.*;
import io.reactivex.rxjava3.internal.fuseable.*;
@@ -46,10 +46,10 @@
* onSubscribe (onSuccess | onError | onComplete)?
*
*
- * Note that {@code onSuccess}, {@code onError} and {@code onComplete} are mutually exclusive events; unlike {@code Observable},
+ * Note that {@code onSuccess}, {@code onError} and {@code onComplete} are mutually exclusive events; unlike {@link Observable},
* {@code onSuccess} is never followed by {@code onError} or {@code onComplete}.
*
- * Like {@link Observable}, a running {@code Maybe} can be stopped through the {@link Disposable} instance
+ * Like {@code Observable}, a running {@code Maybe} can be stopped through the {@link Disposable} instance
* provided to consumers through {@link MaybeObserver#onSubscribe}.
*
* Like an {@code Observable}, a {@code Maybe} is lazy, can be either "hot" or "cold", synchronous or
@@ -61,7 +61,7 @@
*
*
*
- * See {@link Flowable} or {@link Observable} for the
+ * See {@link Flowable} or {@code Observable} for the
* implementation of the Reactive Pattern for a stream or vector of values.
*
* Example:
@@ -112,8 +112,8 @@
public abstract class Maybe implements MaybeSource {
/**
- * Runs multiple MaybeSources and signals the events of the first one that signals (disposing
- * the rest).
+ * Runs multiple {@link MaybeSource}s provided by an {@link Iterable} sequence and
+ * signals the events of the first one that signals (disposing the rest).
*
*
*
@@ -121,9 +121,10 @@ public abstract class Maybe implements MaybeSource {
* - {@code amb} does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources the Iterable sequence of sources. A subscription to each source will
- * occur in the same order as in the Iterable.
- * @return the new Maybe instance
+ * @param sources the {@code Iterable} sequence of sources. A subscription to each source will
+ * occur in the same order as in the {@code Iterable}.
+ * @return the new {@code Maybe} instance
+ * @throws NullPointerException if {@code sources} is {@code null}
*/
@CheckReturnValue
@NonNull
@@ -134,7 +135,7 @@ public static Maybe amb(@NonNull Iterable extends MaybeSource extends
}
/**
- * Runs multiple MaybeSources and signals the events of the first one that signals (disposing
+ * Runs multiple {@link MaybeSource}s and signals the events of the first one that signals (disposing
* the rest).
*
*
@@ -145,7 +146,7 @@ public static Maybe amb(@NonNull Iterable extends MaybeSource extends
* @param the value type
* @param sources the array of sources. A subscription to each source will
* occur in the same order as in the array.
- * @return the new Maybe instance
+ * @return the new {@code Maybe} instance
*/
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
@@ -164,8 +165,8 @@ public static Maybe ambArray(@NonNull MaybeSource extends T>... sources
}
/**
- * Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources provided by
- * an Iterable sequence.
+ * Concatenate the single values, in a non-overlapping fashion, of the {@link MaybeSource} sources provided by
+ * an {@link Iterable} sequence as a {@link Flowable} sequence.
*
*
*
@@ -175,8 +176,9 @@ public static Maybe ambArray(@NonNull MaybeSource extends T>... sources
* - {@code concat} does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources the Iterable sequence of MaybeSource instances
- * @return the new Flowable instance
+ * @param sources the {@code Iterable} sequence of {@code MaybeSource} instances
+ * @return the new {@code Flowable} instance
+ * @throws NullPointerException if {@code sources} is {@code null}
*/
@BackpressureSupport(BackpressureKind.FULL)
@CheckReturnValue
@@ -188,7 +190,7 @@ public static Flowable concat(@NonNull Iterable extends MaybeSource e
}
/**
- * Returns a Flowable that emits the items emitted by two MaybeSources, one after the other.
+ * Returns a {@link Flowable} that emits the items emitted by two {@link MaybeSource}s, one after the other.
*
*
*
@@ -200,10 +202,11 @@ public static Flowable concat(@NonNull Iterable extends MaybeSource e
*
* @param the common value type
* @param source1
- * a MaybeSource to be concatenated
+ * a {@code MaybeSource} to be concatenated
* @param source2
- * a MaybeSource to be concatenated
- * @return a Flowable that emits items emitted by the two source MaybeSources, one after the other.
+ * a {@code MaybeSource} to be concatenated
+ * @return a {@code Flowable} that emits items emitted by the two source {@code MaybeSource}s, one after the other.
+ * @throws NullPointerException if {@code source1} or {@code source2} is {@code null}
* @see ReactiveX operators documentation: Concat
*/
@BackpressureSupport(BackpressureKind.FULL)
@@ -217,7 +220,7 @@ public static Flowable concat(@NonNull MaybeSource extends T> source1,
}
/**
- * Returns a Flowable that emits the items emitted by three MaybeSources, one after the other.
+ * Returns a {@link Flowable} that emits the items emitted by three {@link MaybeSource}s, one after the other.
*
*
*
@@ -229,12 +232,13 @@ public static Flowable concat(@NonNull MaybeSource extends T> source1,
*
* @param the common value type
* @param source1
- * a MaybeSource to be concatenated
+ * a {@code MaybeSource} to be concatenated
* @param source2
- * a MaybeSource to be concatenated
+ * a {@code MaybeSource} to be concatenated
* @param source3
- * a MaybeSource to be concatenated
- * @return a Flowable that emits items emitted by the three source MaybeSources, one after the other.
+ * a {@code MaybeSource} to be concatenated
+ * @return a {@code Flowable} that emits items emitted by the three source {@code MaybeSource}s, one after the other.
+ * @throws NullPointerException if {@code source1}, {@code source2} or {@code source3} is {@code null}
* @see ReactiveX operators documentation: Concat
*/
@BackpressureSupport(BackpressureKind.FULL)
@@ -250,7 +254,7 @@ public static Flowable concat(
}
/**
- * Returns a Flowable that emits the items emitted by four MaybeSources, one after the other.
+ * Returns a {@link Flowable} that emits the items emitted by four {@link MaybeSource}s, one after the other.
*
*
*
@@ -262,14 +266,15 @@ public static Flowable concat(
*
* @param the common value type
* @param source1
- * a MaybeSource to be concatenated
+ * a {@code MaybeSource} to be concatenated
* @param source2
- * a MaybeSource to be concatenated
+ * a {@code MaybeSource} to be concatenated
* @param source3
- * a MaybeSource to be concatenated
+ * a {@code MaybeSource} to be concatenated
* @param source4
- * a MaybeSource to be concatenated
- * @return a Flowable that emits items emitted by the four source MaybeSources, one after the other.
+ * a {@code MaybeSource} to be concatenated
+ * @return a {@code Flowable} that emits items emitted by the four source {@code MaybeSource}s, one after the other.
+ * @throws NullPointerException if {@code source1}, {@code source2}, {@code source3} or {@code source4} is {@code null}
* @see ReactiveX operators documentation: Concat
*/
@BackpressureSupport(BackpressureKind.FULL)
@@ -286,21 +291,21 @@ public static Flowable concat(
}
/**
- * Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources provided by
- * a Publisher sequence.
+ * Concatenate the single values, in a non-overlapping fashion, of the {@link MaybeSource} sources provided by
+ * a {@link Publisher} sequence as a {@link Flowable} sequence.
*
*
*
* - Backpressure:
* - The returned {@code Flowable} honors the backpressure of the downstream consumer and
* expects the {@code Publisher} to honor backpressure as well. If the sources {@code Publisher}
- * violates this, a {@link io.reactivex.rxjava3.exceptions.MissingBackpressureException} is signalled.
+ * violates this, a {@link io.reactivex.rxjava3.exceptions.MissingBackpressureException} is signaled.
* - Scheduler:
* - {@code concat} does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources the Publisher of MaybeSource instances
- * @return the new Flowable instance
+ * @param sources the {@code Publisher} of {@code MaybeSource} instances
+ * @return the new {@code Flowable} instance
*/
@BackpressureSupport(BackpressureKind.FULL)
@CheckReturnValue
@@ -311,22 +316,24 @@ public static Flowable concat(@NonNull Publisher extends MaybeSource
}
/**
- * Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources provided by
- * a Publisher sequence.
+ * Concatenate the single values, in a non-overlapping fashion, of the {@link MaybeSource} sources provided by
+ * a {@link Publisher} sequence as a {@link Flowable} sequence.
*
*
*
* - Backpressure:
* - The returned {@code Flowable} honors the backpressure of the downstream consumer and
* expects the {@code Publisher} to honor backpressure as well. If the sources {@code Publisher}
- * violates this, a {@link io.reactivex.rxjava3.exceptions.MissingBackpressureException} is signalled.
+ * violates this, a {@link io.reactivex.rxjava3.exceptions.MissingBackpressureException} is signaled.
* - Scheduler:
* - {@code concat} does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources the Publisher of MaybeSource instances
- * @param prefetch the number of MaybeSources to prefetch from the Publisher
- * @return the new Flowable instance
+ * @param sources the {@code Publisher} of {@code MaybeSource} instances
+ * @param prefetch the number of {@code MaybeSource}s to prefetch from the {@code Publisher}
+ * @throws NullPointerException if {@code sources} is {@code null}
+ * @throws IllegalArgumentException if {@code prefetch} is non-positive
+ * @return the new {@code Flowable} instance
*/
@BackpressureSupport(BackpressureKind.FULL)
@CheckReturnValue
@@ -340,7 +347,8 @@ public static Flowable concat(@NonNull Publisher extends MaybeSource
}
/**
- * Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources in the array.
+ * Concatenate the single values, in a non-overlapping fashion, of the {@link MaybeSource} sources in the array
+ * as a {@link Flowable} sequence.
*
*
*
@@ -350,8 +358,9 @@ public static Flowable concat(@NonNull Publisher extends MaybeSource
* - {@code concatArray} does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources the array of MaybeSource instances
- * @return the new Flowable instance
+ * @param sources the array of {@code MaybeSource} instances
+ * @return the new {@code Flowable} instance
+ * @throws NullPointerException if {@code sources} is {@code null}
*/
@BackpressureSupport(BackpressureKind.FULL)
@CheckReturnValue
@@ -372,8 +381,8 @@ public static Flowable concatArray(@NonNull MaybeSource extends T>... s
}
/**
- * Concatenates a variable number of MaybeSource sources and delays errors from any of them
- * till all terminate.
+ * Concatenates a variable number of {@link MaybeSource} sources and delays errors from any of them
+ * till all terminate as a {@link Flowable} sequence.
*
*
*
@@ -384,8 +393,8 @@ public static Flowable concatArray(@NonNull MaybeSource extends T>... s
*
* @param sources the array of sources
* @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 {@code sources} is {@code null}
*/
@BackpressureSupport(BackpressureKind.FULL)
@CheckReturnValue
@@ -405,10 +414,10 @@ public static Flowable concatArrayDelayError(@NonNull MaybeSource exten
}
/**
- * Concatenates a sequence of MaybeSource eagerly into a single stream of values.
+ * Concatenates a sequence of {@link MaybeSource} eagerly into a {@link Flowable} sequence.
*
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
- * source MaybeSources. The operator buffers the value emitted by these MaybeSources and then drains them
+ * source {@code MaybeSource}s. The operator buffers the value emitted by these {@code MaybeSource}s and then drains them
* in order, each one after the previous one completes.
*
*
@@ -419,8 +428,8 @@ public static Flowable concatArrayDelayError(@NonNull MaybeSource exten
* - This method does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources a sequence of MaybeSources that need to be eagerly concatenated
- * @return the new Flowable instance with the specified concatenation behavior
+ * @param sources a sequence of {@code MaybeSource}s that need to be eagerly concatenated
+ * @return the new {@code Flowable} instance with the specified concatenation behavior
*/
@SuppressWarnings({ "rawtypes", "unchecked" })
@BackpressureSupport(BackpressureKind.FULL)
@@ -433,8 +442,9 @@ public static Flowable concatArrayEager(@NonNull MaybeSource extends T>
}
/**
- * Concatenates the Iterable sequence of MaybeSources into a single sequence by subscribing to each MaybeSource,
- * one after the other, one at a time and delays any errors till the all inner MaybeSources terminate.
+ * Concatenates the {@link Iterable} sequence of {@link MaybeSource}s into a single sequence by subscribing to each {@code MaybeSource},
+ * one after the other, one at a time and delays any errors till the all inner {@code MaybeSource}s terminate
+ * as a {@link Flowable} sequence.
*
*
*
@@ -445,8 +455,9 @@ public static Flowable concatArrayEager(@NonNull MaybeSource extends T>
*
*
* @param the common element base type
- * @param sources the Iterable sequence of MaybeSources
- * @return the new Flowable with the concatenating behavior
+ * @param sources the {@code Iterable} sequence of {@code MaybeSource}s
+ * @return the new {@code Flowable} with the concatenating behavior
+ * @throws NullPointerException if {@code sources} is {@code null}
*/
@SuppressWarnings({ "unchecked", "rawtypes" })
@BackpressureSupport(BackpressureKind.FULL)
@@ -459,8 +470,9 @@ public static Flowable concatDelayError(@NonNull Iterable extends Maybe
}
/**
- * Concatenates the Publisher sequence of Publishers into a single sequence by subscribing to each inner Publisher,
- * one after the other, one at a time and delays any errors till the all inner and the outer Publishers terminate.
+ * Concatenates the {@link Publisher} sequence of {@link MaybeSource}s into a single sequence by subscribing to each inner {@code MaybeSource},
+ * one after the other, one at a time and delays any errors till the all inner and the outer {@code Publisher} terminate
+ * as a {@link Flowable} sequence.
*
*
*
@@ -471,8 +483,8 @@ public static Flowable concatDelayError(@NonNull Iterable extends Maybe
*
*
* @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 MaybeSource}s
+ * @return the new {@code Flowable} with the concatenating behavior
*/
@SuppressWarnings({ "unchecked", "rawtypes" })
@BackpressureSupport(BackpressureKind.FULL)
@@ -484,10 +496,10 @@ public static Flowable concatDelayError(@NonNull Publisher extends Mayb
}
/**
- * Concatenates a sequence of MaybeSources eagerly into a single stream of values.
+ * Concatenates a sequence of {@link MaybeSource}s eagerly into a {@link Flowable} sequence.
*
* Eager concatenation means that once a subscriber subscribes, this operator subscribes to all of the
- * source MaybeSources. The operator buffers the values emitted by these MaybeSources and then drains them
+ * source {@code MaybeSource}s. The operator buffers the values emitted by these {@code MaybeSource}s and then drains them
* in order, each one after the previous one completes.
*
*
@@ -498,8 +510,8 @@ public static Flowable concatDelayError(@NonNull Publisher extends Mayb
* - This method does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param sources a sequence of MaybeSource that need to be eagerly concatenated
- * @return the new Flowable instance with the specified concatenation behavior
+ * @param sources a sequence of {@code MaybeSource} that need to be eagerly concatenated
+ * @return the new {@code Flowable} instance with the specified concatenation behavior
*/
@SuppressWarnings({ "rawtypes", "unchecked" })
@BackpressureSupport(BackpressureKind.FULL)
@@ -511,24 +523,24 @@ public static Flowable concatEager(@NonNull Iterable extends MaybeSourc
}
/**
- * Concatenates a Publisher sequence of MaybeSources eagerly into a single stream of values.
+ * Concatenates a {@link Publisher} sequence of {@link MaybeSource}s eagerly into a {@link Flowable} sequence.
*
* 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 MaybeSource}s as they are observed. The operator buffers the values emitted by these
+ * {@code MaybeSource}s and then drains them in order, each one after the previous one completes.
*
*
*
* - Backpressure:
- * - Backpressure is honored towards the downstream and the outer Publisher is
+ *
- Backpressure is honored towards the downstream and the outer {@code Publisher} is
* expected to support backpressure. Violating this assumption, the operator will
* signal {@link io.reactivex.rxjava3.exceptions.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 MaybeSource}s that need to be eagerly concatenated
+ * @return the new {@code Flowable} instance with the specified concatenation behavior
*/
@SuppressWarnings({ "rawtypes", "unchecked" })
@BackpressureSupport(BackpressureKind.FULL)
@@ -540,7 +552,7 @@ public static Flowable concatEager(@NonNull Publisher extends MaybeSour
}
/**
- * Provides an API (via a cold Maybe) that bridges the reactive world with the callback-style world.
+ * Provides an API (via a cold {@code Maybe}) that bridges the reactive world with the callback-style world.
*
* Example:
*
@@ -571,15 +583,16 @@ public static Flowable concatEager(@NonNull Publisher extends MaybeSour
* Whenever a {@link MaybeObserver} subscribes to the returned {@code Maybe}, the provided
* {@link MaybeOnSubscribe} callback is invoked with a fresh instance of a {@link MaybeEmitter}
* that will interact only with that specific {@code MaybeObserver}. If this {@code MaybeObserver}
- * disposes the flow (making {@link MaybeEmitter#isDisposed} return true),
+ * disposes the flow (making {@link MaybeEmitter#isDisposed} return {@code true}),
* other observers subscribed to the same returned {@code Maybe} are not affected.
*
* - Scheduler:
* - {@code create} does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param onSubscribe the emitter that is called when a MaybeObserver subscribes to the returned {@code Maybe}
- * @return the new Maybe instance
+ * @param onSubscribe the emitter that is called when a {@code MaybeObserver} subscribes to the returned {@code Maybe}
+ * @return the new {@code Maybe} instance
+ * @throws NullPointerException if {@code onSubscribe} is {@code null}
* @see MaybeOnSubscribe
* @see Cancellable
*/
@@ -592,16 +605,17 @@ public static Maybe create(@NonNull MaybeOnSubscribe onSubscribe) {
}
/**
- * Calls a Supplier for each individual MaybeObserver to return the actual MaybeSource source to
+ * Calls a {@link Supplier} for each individual {@link MaybeObserver} to return the actual {@link MaybeSource} source to
* be subscribed to.
*
* - Scheduler:
* - {@code defer} does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param maybeSupplier the Supplier that is called for each individual MaybeObserver and
- * returns a MaybeSource instance to subscribe to
- * @return the new Maybe instance
+ * @param maybeSupplier the {@code Supplier} that is called for each individual {@code MaybeObserver} and
+ * returns a {@code MaybeSource} instance to subscribe to
+ * @return the new {@code Maybe} instance
+ * @throws NullPointerException if {@code maybeSupplier} is {@code null}
*/
@CheckReturnValue
@NonNull
@@ -612,7 +626,7 @@ public static Maybe defer(@NonNull Supplier extends MaybeSource exten
}
/**
- * Returns a (singleton) Maybe instance that calls {@link MaybeObserver#onComplete onComplete}
+ * Returns a (singleton) {@code Maybe} instance that calls {@link MaybeObserver#onComplete onComplete}
* immediately.
*
*
@@ -621,7 +635,7 @@ public static Maybe defer(@NonNull Supplier extends MaybeSource exten
* - {@code empty} does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @return the new Maybe instance
+ * @return the new {@code Maybe} instance
*/
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
@@ -632,7 +646,7 @@ public static Maybe empty() {
}
/**
- * Returns a Maybe that invokes a subscriber's {@link MaybeObserver#onError onError} method when the
+ * Returns a {@code Maybe} that invokes a subscriber's {@link MaybeObserver#onError onError} method when the
* subscriber subscribes to it.
*
*
@@ -641,25 +655,26 @@ public static Maybe empty() {
* {@code error} does not operate by default on a particular {@link Scheduler}.
*
*
- * @param exception
- * the particular Throwable to pass to {@link MaybeObserver#onError onError}
+ * @param error
+ * the particular {@link Throwable} to pass to {@link MaybeObserver#onError onError}
* @param
- * the type of the item (ostensibly) emitted by the Maybe
- * @return a Maybe that invokes the subscriber's {@link MaybeObserver#onError onError} method when
+ * the type of the item (ostensibly) emitted by the {@code Maybe}
+ * @return a {@code Maybe} that invokes the subscriber's {@link MaybeObserver#onError onError} method when
* the subscriber subscribes to it
+ * @throws NullPointerException if {@code error} is {@code null}
* @see ReactiveX operators documentation: Throw
*/
@CheckReturnValue
@NonNull
@SchedulerSupport(SchedulerSupport.NONE)
- public static Maybe error(@NonNull Throwable exception) {
- Objects.requireNonNull(exception, "exception is null");
- return RxJavaPlugins.onAssembly(new MaybeError<>(exception));
+ public static Maybe error(@NonNull Throwable error) {
+ Objects.requireNonNull(error, "error is null");
+ return RxJavaPlugins.onAssembly(new MaybeError<>(error));
}
/**
- * Returns a Maybe that invokes a {@link MaybeObserver}'s {@link MaybeObserver#onError onError} method when the
- * MaybeObserver subscribes to it.
+ * Returns a {@code Maybe} that invokes a {@link MaybeObserver}'s {@link MaybeObserver#onError onError} method when the
+ * {@code MaybeObserver} subscribes to it.
*
*
*
@@ -668,11 +683,12 @@ public static Maybe error(@NonNull Throwable exception) {
*
*
* @param supplier
- * a Supplier factory to return a Throwable for each individual MaybeObserver
+ * a {@link Supplier} factory to return a {@link Throwable} for each individual {@code MaybeObserver}
* @param
- * the type of the items (ostensibly) emitted by the Maybe
- * @return a Maybe that invokes the {@link MaybeObserver}'s {@link MaybeObserver#onError onError} method when
- * the MaybeObserver subscribes to it
+ * the type of the items (ostensibly) emitted by the {@code Maybe}
+ * @return a {@code Maybe} that invokes the {@code MaybeObserver.onError} method when
+ * the {@code MaybeObserver} subscribes to it
+ * @throws NullPointerException if {@code supplier} is {@code null}
* @see ReactiveX operators documentation: Throw
*/
@CheckReturnValue
@@ -684,13 +700,13 @@ public static Maybe error(@NonNull Supplier extends Throwable> supplier
}
/**
- * Returns a Maybe instance that runs the given Action for each subscriber and
+ * Returns a {@code Maybe} instance that runs the given {@link Action} for each subscriber and
* emits either its exception or simply completes.
*
* - Scheduler:
* - {@code fromAction} does not operate by default on a particular {@link Scheduler}.
* - Error handling:
- * - If the {@link Action} throws an exception, the respective {@link Throwable} is
+ *
- If the {@code Action} throws an exception, the respective {@link Throwable} is
* delivered to the downstream via {@link MaybeObserver#onError(Throwable)},
* except when the downstream has disposed this {@code Maybe} source.
* In this latter case, the {@code Throwable} is delivered to the global error handler via
@@ -698,29 +714,29 @@ public static Maybe error(@NonNull Supplier extends Throwable> supplier
*
*
* @param the target type
- * @param run the runnable to run for each subscriber
- * @return the new Maybe instance
- * @throws NullPointerException if run is null
+ * @param action the {@code Action} to run for each subscriber
+ * @return the new {@code Maybe} instance
+ * @throws NullPointerException if {@code action} is {@code null}
*/
@CheckReturnValue
@NonNull
@SchedulerSupport(SchedulerSupport.NONE)
- public static Maybe fromAction(@NonNull Action run) {
- Objects.requireNonNull(run, "run is null");
- return RxJavaPlugins.onAssembly(new MaybeFromAction<>(run));
+ public static Maybe fromAction(@NonNull Action action) {
+ Objects.requireNonNull(action, "action is null");
+ return RxJavaPlugins.onAssembly(new MaybeFromAction<>(action));
}
/**
- * Wraps a CompletableSource into a Maybe.
+ * Wraps a {@link CompletableSource} into a {@code Maybe}.
*
*
* - Scheduler:
* - {@code fromCompletable} does not operate by default on a particular {@link Scheduler}.
*
* @param the target type
- * @param completableSource the CompletableSource to convert from
- * @return the new Maybe instance
- * @throws NullPointerException if completable is null
+ * @param completableSource the {@code CompletableSource} to convert from
+ * @return the new {@code Maybe} instance
+ * @throws NullPointerException if {@code completableSource} is {@code null}
*/
@CheckReturnValue
@NonNull
@@ -731,16 +747,16 @@ public static Maybe fromCompletable(@NonNull CompletableSource completabl
}
/**
- * Wraps a SingleSource into a Maybe.
+ * Wraps a {@link SingleSource} into a {@code Maybe}.
*
*
* - Scheduler:
* - {@code fromSingle} does not operate by default on a particular {@link Scheduler}.
*
* @param the target type
- * @param singleSource the SingleSource to convert from
- * @return the new Maybe instance
- * @throws NullPointerException if single is null
+ * @param singleSource the {@code SingleSource} to convert from
+ * @return the new {@code Maybe} instance
+ * @throws NullPointerException if {@code singleSource} is {@code null}
*/
@CheckReturnValue
@NonNull
@@ -751,17 +767,17 @@ public static Maybe fromSingle(@NonNull SingleSource singleSource) {
}
/**
- * Returns a {@link Maybe} that invokes the given {@link Callable} for each individual {@link MaybeObserver} that
- * subscribes and emits the resulting non-null item via {@code onSuccess} while
+ * Returns a {@code Maybe} that invokes the given {@link Callable} for each individual {@link MaybeObserver} that
+ * subscribes and emits the resulting non-{@code null} item via {@code onSuccess} while
* considering a {@code null} result from the {@code Callable} as indication for valueless completion
* via {@code onComplete}.
*
* This operator allows you to defer the execution of the given {@code Callable} until a {@code MaybeObserver}
- * subscribes to the returned {@link Maybe}. In other terms, this source operator evaluates the given
+ * subscribes to the returned {@code Maybe}. In other terms, this source operator evaluates the given
* {@code Callable} "lazily".
*
* Note that the {@code null} handling of this operator differs from the similar source operators in the other
- * {@link io.reactivex.rxjava3.core base reactive classes}. Those operators signal a {@code NullPointerException} if the value returned by their
+ * {@link io.reactivex.rxjava3.core base reactive classes}. Those operators signal a {@link NullPointerException} if the value returned by their
* {@code Callable} is {@code null} while this {@code fromCallable} considers it to indicate the
* returned {@code Maybe} is empty.
*
@@ -778,11 +794,12 @@ public static Maybe fromSingle(@NonNull SingleSource singleSource) {
*
*
* @param callable
- * a {@link Callable} instance whose execution should be deferred and performed for each individual
- * {@code MaybeObserver} that subscribes to the returned {@link Maybe}.
+ * a {@code Callable} instance whose execution should be deferred and performed for each individual
+ * {@code MaybeObserver} that subscribes to the returned {@code Maybe}.
* @param
- * the type of the item emitted by the {@link Maybe}.
- * @return a new Maybe instance
+ * the type of the item emitted by the {@code Maybe}.
+ * @return a new {@code Maybe} instance
+ * @throws NullPointerException if {@code callable} is {@code null}
* @see #defer(Supplier)
* @see #fromSupplier(Supplier)
*/
@@ -795,29 +812,29 @@ public static Maybe fromSingle(@NonNull SingleSource singleSource) {
}
/**
- * Converts a {@link Future} into a Maybe, treating a null result as an indication of emptiness.
+ * Converts a {@link Future} into a {@code Maybe}, treating a {@code null} result as an indication of emptiness.
*
*
*
- * You can convert any object that supports the {@link Future} interface into a Maybe that emits the
- * return value of the {@link Future#get} method of that object, by passing the object into the {@code from}
- * method.
+ * The operator calls {@link Future#get()}, which is a blocking method, on the subscription thread.
+ * It is recommended applying {@link #subscribeOn(Scheduler)} to move this blocking wait to a
+ * background thread, and if the {@link Scheduler} supports it, interrupt the wait when the flow
+ * is disposed.
*
- * Important note: This Maybe is blocking; you cannot dispose it.
- *
- * Unlike 1.x, disposing the Maybe won't cancel the future. If necessary, one can use composition to achieve the
+ * Unlike 1.x, disposing the {@code Maybe} won't cancel the future. If necessary, one can use composition to achieve the
* cancellation effect: {@code futureMaybe.doOnDispose(() -> future.cancel(true));}.
*
* - Scheduler:
- * - {@code fromFuture} does not operate by default on a particular {@link Scheduler}.
+ * - {@code fromFuture} does not operate by default on a particular {@code Scheduler}.
*
*
* @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 Maybe
- * @return a Maybe 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 Maybe}
+ * @return a {@code Maybe} that emits the item from the source {@code Future}
+ * @throws NullPointerException if {@code future} is {@code null}
* @see ReactiveX operators documentation: From
*/
@CheckReturnValue
@@ -829,33 +846,33 @@ public static Maybe fromSingle(@NonNull SingleSource singleSource) {
}
/**
- * Converts a {@link Future} into a Maybe, with a timeout on the Future.
+ * Converts a {@link Future} into a {@code Maybe}, with a timeout on the {@code Future}.
*
*
*
- * You can convert any object that supports the {@link Future} interface into a Maybe that emits the
- * return value of the {@link Future#get} method of that object, by passing the object into the {@code fromFuture}
- * method.
+ * The operator calls {@link Future#get(long, TimeUnit)}, which is a blocking method, on the subscription thread.
+ * It is recommended applying {@link #subscribeOn(Scheduler)} to move this blocking wait to a
+ * background thread, and if the {@link Scheduler} supports it, interrupt the wait when the flow
+ * is disposed.
*
- * Unlike 1.x, disposing the Maybe won't cancel the future. If necessary, one can use composition to achieve the
+ * Unlike 1.x, disposing the {@code Maybe} won't cancel the future. If necessary, one can use composition to achieve the
* cancellation effect: {@code futureMaybe.doOnCancel(() -> future.cancel(true));}.
- *
- * Important note: This Maybe is blocking on the thread it gets subscribed on; you cannot dispose it.
*
* - Scheduler:
- * - {@code fromFuture} does not operate by default on a particular {@link Scheduler}.
+ * - {@code fromFuture} does not operate by default on a particular {@code Scheduler}.
*
*
* @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 Maybe
- * @return a Maybe 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 Maybe}
+ * @return a {@code Maybe} that emits the item from the source {@code Future}
+ * @throws NullPointerException if {@code future} or {@code unit} is {@code null}
* @see ReactiveX operators documentation: From
*/
@CheckReturnValue
@@ -868,16 +885,16 @@ public static Maybe fromSingle(@NonNull SingleSource singleSource) {
}
/**
- * Returns a Maybe instance that runs the given Action for each subscriber and
+ * Returns a {@code Maybe} instance that runs the given {@link Runnable} for each subscriber and
* emits either its exception or simply completes.
*
* - Scheduler:
* - {@code fromRunnable} does not operate by default on a particular {@link Scheduler}.
*
* @param the target type
- * @param run the runnable to run for each subscriber
- * @return the new Maybe instance
- * @throws NullPointerException if run is null
+ * @param run the {@code Runnable} to run for each subscriber
+ * @return the new {@code Maybe} instance
+ * @throws NullPointerException if {@code run} is {@code null}
*/
@CheckReturnValue
@NonNull
@@ -888,19 +905,19 @@ public static Maybe fromRunnable(@NonNull Runnable run) {
}
/**
- * Returns a {@link Maybe} that invokes the given {@link Supplier} for each individual {@link MaybeObserver} that
- * subscribes and emits the resulting non-null item via {@code onSuccess} while
+ * Returns a {@code Maybe} that invokes the given {@link Supplier} for each individual {@link MaybeObserver} that
+ * subscribes and emits the resulting non-{@code null} item via {@code onSuccess} while
* considering a {@code null} result from the {@code Supplier} as indication for valueless completion
* via {@code onComplete}.
*
* This operator allows you to defer the execution of the given {@code Supplier} until a {@code MaybeObserver}
- * subscribes to the returned {@link Maybe}. In other terms, this source operator evaluates the given
+ * subscribes to the returned {@code Maybe}. In other terms, this source operator evaluates the given
* {@code Supplier} "lazily".
*
*
*
* Note that the {@code null} handling of this operator differs from the similar source operators in the other
- * {@link io.reactivex.rxjava3.core base reactive classes}. Those operators signal a {@code NullPointerException} if the value returned by their
+ * {@link io.reactivex.rxjava3.core base reactive classes}. Those operators signal a {@link NullPointerException} if the value returned by their
* {@code Supplier} is {@code null} while this {@code fromSupplier} considers it to indicate the
* returned {@code Maybe} is empty.
*
@@ -917,11 +934,12 @@ public static Maybe fromRunnable(@NonNull Runnable run) {
*
*
* @param supplier
- * a {@link Supplier} instance whose execution should be deferred and performed for each individual
- * {@code MaybeObserver} that subscribes to the returned {@link Maybe}.
+ * a {@code Supplier} instance whose execution should be deferred and performed for each individual
+ * {@code MaybeObserver} that subscribes to the returned {@code Maybe}.
* @param
- * the type of the item emitted by the {@link Maybe}.
- * @return a new Maybe instance
+ * the type of the item emitted by the {@code Maybe}.
+ * @return a new {@code Maybe} instance
+ * @throws NullPointerException if {@code supplier} is {@code null}
* @see #defer(Supplier)
* @see #fromCallable(Callable)
* @since 3.0.0
@@ -951,6 +969,7 @@ public static Maybe fromRunnable(@NonNull Runnable run) {
* @param
* the type of that item
* @return a {@code Maybe} that emits {@code item}
+ * @throws NullPointerException if {@code item} is {@code null}
* @see ReactiveX operators documentation: Just
*/
@CheckReturnValue
@@ -962,21 +981,21 @@ public static Maybe fromRunnable(@NonNull Runnable run) {
}
/**
- * Merges an Iterable sequence of MaybeSource instances into a single Flowable sequence,
- * running all MaybeSources at once.
+ * Merges an {@link Iterable} sequence of {@link MaybeSource} instances into a single {@link Flowable} sequence,
+ * running all {@code MaybeSource}s at once.
*
* - Backpressure:
* - The operator honors backpressure from downstream.
* - Scheduler:
* - {@code merge} does not operate by default on a particular {@link Scheduler}.
* - Error handling:
- * - If any of the source {@code MaybeSource}s signal a {@code Throwable} via {@code onError}, the resulting
+ *
- If any of the source {@code MaybeSource}s signal a {@link Throwable} via {@code onError}, the resulting
* {@code Flowable} terminates with that {@code Throwable} and all other source {@code MaybeSource}s are disposed.
* If more than one {@code MaybeSource} signals an error, the resulting {@code Flowable} may terminate with the
* first one's error or, depending on the concurrency of the sources, may terminate with a
- * {@code CompositeException} containing two or more of the various error signals.
+ * {@link CompositeException} containing two or more of the various error signals.
* {@code Throwable}s that didn't make into the composite will be sent (individually) to the global error handler via
- * {@link RxJavaPlugins#onError(Throwable)} method as {@code UndeliverableException} errors. Similarly, {@code Throwable}s
+ * {@link RxJavaPlugins#onError(Throwable)} method as {@link UndeliverableException} errors. Similarly, {@code Throwable}s
* signaled by source(s) after the returned {@code Flowable} has been cancelled or terminated with a
* (composite) error will be sent to the same global error handler.
* Use {@link #mergeDelayError(Iterable)} to merge sources and terminate only when all source {@code MaybeSource}s
@@ -984,8 +1003,9 @@ public static Maybe fromRunnable(@NonNull Runnable run) {
*
*
* @param the common and resulting value type
- * @param sources the Iterable sequence of MaybeSource sources
- * @return the new Flowable instance
+ * @param sources the {@code Iterable} sequence of {@code MaybeSource} sources
+ * @return the new {@code Flowable} instance
+ * @throws NullPointerException if {@code sources} is {@code null}
* @see #mergeDelayError(Iterable)
*/
@BackpressureSupport(BackpressureKind.FULL)
@@ -997,21 +1017,21 @@ public static Flowable merge(@NonNull Iterable extends MaybeSource ex
}
/**
- * Merges a Flowable sequence of MaybeSource instances into a single Flowable sequence,
- * running all MaybeSources at once.
+ * Merges a {@link Publisher} sequence of {@link MaybeSource} instances into a single {@link Flowable} sequence,
+ * running all {@code MaybeSource}s at once.
*
* - Backpressure:
* - The operator honors backpressure from downstream.
* - Scheduler:
* - {@code merge} does not operate by default on a particular {@link Scheduler}.
* - Error handling:
- * - If any of the source {@code MaybeSource}s signal a {@code Throwable} via {@code onError}, the resulting
+ *
- If any of the source {@code MaybeSource}s signal a {@link Throwable} via {@code onError}, the resulting
* {@code Flowable} terminates with that {@code Throwable} and all other source {@code MaybeSource}s are disposed.
* If more than one {@code MaybeSource} signals an error, the resulting {@code Flowable} may terminate with the
* first one's error or, depending on the concurrency of the sources, may terminate with a
- * {@code CompositeException} containing two or more of the various error signals.
+ * {@link CompositeException} containing two or more of the various error signals.
* {@code Throwable}s that didn't make into the composite will be sent (individually) to the global error handler via
- * {@link RxJavaPlugins#onError(Throwable)} method as {@code UndeliverableException} errors. Similarly, {@code Throwable}s
+ * {@link RxJavaPlugins#onError(Throwable)} method as {@link UndeliverableException} errors. Similarly, {@code Throwable}s
* signaled by source(s) after the returned {@code Flowable} has been cancelled or terminated with a
* (composite) error will be sent to the same global error handler.
* Use {@link #mergeDelayError(Publisher)} to merge sources and terminate only when all source {@code MaybeSource}s
@@ -1019,8 +1039,8 @@ public static Flowable merge(@NonNull Iterable extends MaybeSource ex
*
*
* @param the common and resulting value type
- * @param sources the Flowable sequence of MaybeSource sources
- * @return the new Flowable instance
+ * @param sources the {@code Flowable} sequence of {@code MaybeSource} sources
+ * @return the new {@code Flowable} instance
* @see #mergeDelayError(Publisher)
*/
@BackpressureSupport(BackpressureKind.FULL)
@@ -1032,21 +1052,21 @@ public static Flowable merge(@NonNull Publisher extends MaybeSource e
}
/**
- * Merges a Flowable sequence of MaybeSource instances into a single Flowable sequence,
- * running at most maxConcurrency MaybeSources at once.
+ * Merges a {@link Publisher} sequence of {@link MaybeSource} instances into a single {@link Flowable} sequence,
+ * running at most maxConcurrency {@code MaybeSource}s at once.
*
* - Backpressure:
* - The operator honors backpressure from downstream.
* - Scheduler:
* - {@code merge} does not operate by default on a particular {@link Scheduler}.
* - Error handling:
- * - If any of the source {@code MaybeSource}s signal a {@code Throwable} via {@code onError}, the resulting
+ *
- If any of the source {@code MaybeSource}s signal a {@link Throwable} via {@code onError}, the resulting
* {@code Flowable} terminates with that {@code Throwable} and all other source {@code MaybeSource}s are disposed.
* If more than one {@code MaybeSource} signals an error, the resulting {@code Flowable} may terminate with the
* first one's error or, depending on the concurrency of the sources, may terminate with a
- * {@code CompositeException} containing two or more of the various error signals.
+ * {@link CompositeException} containing two or more of the various error signals.
* {@code Throwable}s that didn't make into the composite will be sent (individually) to the global error handler via
- * {@link RxJavaPlugins#onError(Throwable)} method as {@code UndeliverableException} errors. Similarly, {@code Throwable}s
+ * {@link RxJavaPlugins#onError(Throwable)} method as {@link UndeliverableException} errors. Similarly, {@code Throwable}s
* signaled by source(s) after the returned {@code Flowable} has been cancelled or terminated with a
* (composite) error will be sent to the same global error handler.
* Use {@link #mergeDelayError(Publisher, int)} to merge sources and terminate only when all source {@code MaybeSource}s
@@ -1054,9 +1074,11 @@ public static Flowable merge(@NonNull Publisher extends MaybeSource e
*
*
* @param the common and resulting value type
- * @param sources the Flowable sequence of MaybeSource sources
- * @param maxConcurrency the maximum number of concurrently running MaybeSources
- * @return the new Flowable instance
+ * @param sources the {@code Flowable} sequence of {@code MaybeSource} sources
+ * @param maxConcurrency the maximum number of concurrently running {@code MaybeSource}s
+ * @return the new {@code Flowable} instance
+ * @throws NullPointerException if {@code sources} is {@code null}
+ * @throws IllegalArgumentException if {@code maxConcurrency} is non-positive
* @see #mergeDelayError(Publisher, int)
*/
@BackpressureSupport(BackpressureKind.FULL)
@@ -1071,7 +1093,7 @@ public static Flowable merge(@NonNull Publisher extends MaybeSource e
}
/**
- * Flattens a {@code MaybeSource} that emits a {@code MaybeSource} into a single {@code MaybeSource} that emits the item
+ * Flattens a {@link MaybeSource} that emits a {@code MaybeSource} into a single {@code MaybeSource} that emits the item
* emitted by the nested {@code MaybeSource}, without any transformation.
*
*
@@ -1079,8 +1101,8 @@ public static Flowable merge(@NonNull Publisher extends MaybeSource e
* Scheduler:
* {@code merge} does not operate by default on a particular {@link Scheduler}.
* Error handling:
- * The resulting {@code Maybe} emits the outer source's or the inner {@code MaybeSource}'s {@code Throwable} as is.
- * Unlike the other {@code merge()} operators, this operator won't and can't produce a {@code CompositeException} because there is
+ * The resulting {@code Maybe} emits the outer source's or the inner {@code MaybeSource}'s {@link Throwable} as is.
+ * Unlike the other {@code merge()} operators, this operator won't and can't produce a {@link CompositeException} because there is
* only one possibility for the outer or the inner {@code MaybeSource} to emit an {@code onError} signal.
* Therefore, there is no need for a {@code mergeDelayError(MaybeSource>)} operator.
*
@@ -1091,6 +1113,7 @@ public static Flowable merge(@NonNull Publisher extends MaybeSource e
* a {@code MaybeSource} that emits a {@code MaybeSource}
* @return a {@code Maybe} that emits the item that is the result of flattening the {@code MaybeSource} emitted
* by {@code source}
+ * @throws NullPointerException if {@code source} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@CheckReturnValue
@@ -1103,11 +1126,11 @@ public static Maybe merge(@NonNull MaybeSource extends MaybeSource ex
}
/**
- * Flattens two MaybeSources into a single Flowable, without any transformation.
+ * Flattens two {@link MaybeSource}s into a single {@link Flowable}, without any transformation.
*
*
*
- * You can combine items emitted by multiple MaybeSources so that they appear as a single Flowable, by
+ * You can combine items emitted by multiple {@code MaybeSource}s so that they appear as a single {@code Flowable}, by
* using the {@code merge} method.
*
* - Backpressure:
@@ -1115,13 +1138,13 @@ public static Maybe merge(@NonNull MaybeSource extends MaybeSource ex
* - Scheduler:
* - {@code merge} does not operate by default on a particular {@link Scheduler}.
* - Error handling:
- * - If any of the source {@code MaybeSource}s signal a {@code Throwable} via {@code onError}, the resulting
+ *
- If any of the source {@code MaybeSource}s signal a {@link Throwable} via {@code onError}, the resulting
* {@code Flowable} terminates with that {@code Throwable} and all other source {@code MaybeSource}s are disposed.
* If more than one {@code MaybeSource} signals an error, the resulting {@code Flowable} may terminate with the
* first one's error or, depending on the concurrency of the sources, may terminate with a
- * {@code CompositeException} containing two or more of the various error signals.
+ * {@link CompositeException} containing two or more of the various error signals.
* {@code Throwable}s that didn't make into the composite will be sent (individually) to the global error handler via
- * {@link RxJavaPlugins#onError(Throwable)} method as {@code UndeliverableException} errors. Similarly, {@code Throwable}s
+ * {@link RxJavaPlugins#onError(Throwable)} method as {@link UndeliverableException} errors. Similarly, {@code Throwable}s
* signaled by source(s) after the returned {@code Flowable} has been cancelled or terminated with a
* (composite) error will be sent to the same global error handler.
* Use {@link #mergeDelayError(MaybeSource, MaybeSource)} to merge sources and terminate only when all source {@code MaybeSource}s
@@ -1131,10 +1154,11 @@ public static Maybe merge(@NonNull MaybeSource extends MaybeSource ex
*
* @param the common value type
* @param source1
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source2
- * a MaybeSource to be merged
- * @return a Flowable that emits all of the items emitted by the source MaybeSources
+ * a {@code MaybeSource} to be merged
+ * @return a {@code Flowable} that emits all of the items emitted by the source {@code MaybeSource}s
+ * @throws NullPointerException if {@code source1} or {@code source2} is {@code null}
* @see ReactiveX operators documentation: Merge
* @see #mergeDelayError(MaybeSource, MaybeSource)
*/
@@ -1151,11 +1175,11 @@ public static Flowable merge(
}
/**
- * Flattens three MaybeSources into a single Flowable, without any transformation.
+ * Flattens three {@link MaybeSource}s into a single {@link Flowable}, without any transformation.
*
*
*
- * You can combine items emitted by multiple MaybeSources so that they appear as a single Flowable, by using
+ * You can combine items emitted by multiple {@code MaybeSource}s so that they appear as a single {@code Flowable}, by using
* the {@code merge} method.
*
* - Backpressure:
@@ -1163,13 +1187,13 @@ public static Flowable merge(
* - Scheduler:
* - {@code merge} does not operate by default on a particular {@link Scheduler}.
* - Error handling:
- * - If any of the source {@code MaybeSource}s signal a {@code Throwable} via {@code onError}, the resulting
+ *
- If any of the source {@code MaybeSource}s signal a {@link Throwable} via {@code onError}, the resulting
* {@code Flowable} terminates with that {@code Throwable} and all other source {@code MaybeSource}s are disposed.
* If more than one {@code MaybeSource} signals an error, the resulting {@code Flowable} may terminate with the
* first one's error or, depending on the concurrency of the sources, may terminate with a
- * {@code CompositeException} containing two or more of the various error signals.
+ * {@link CompositeException} containing two or more of the various error signals.
* {@code Throwable}s that didn't make into the composite will be sent (individually) to the global error handler via
- * {@link RxJavaPlugins#onError(Throwable)} method as {@code UndeliverableException} errors. Similarly, {@code Throwable}s
+ * {@link RxJavaPlugins#onError(Throwable)} method as {@link UndeliverableException} errors. Similarly, {@code Throwable}s
* signaled by source(s) after the returned {@code Flowable} has been cancelled or terminated with a
* (composite) error will be sent to the same global error handler.
* Use {@link #mergeDelayError(MaybeSource, MaybeSource, MaybeSource)} to merge sources and terminate only when all source {@code MaybeSource}s
@@ -1179,12 +1203,13 @@ public static Flowable merge(
*
* @param the common value type
* @param source1
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source2
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source3
- * a MaybeSource to be merged
- * @return a Flowable that emits all of the items emitted by the source MaybeSources
+ * a {@code MaybeSource} to be merged
+ * @return a {@code Flowable} that emits all of the items emitted by the source {@code MaybeSource}s
+ * @throws NullPointerException if {@code source1}, {@code source2} or {@code source3} is {@code null}
* @see ReactiveX operators documentation: Merge
* @see #mergeDelayError(MaybeSource, MaybeSource, MaybeSource)
*/
@@ -1203,11 +1228,11 @@ public static Flowable merge(
}
/**
- * Flattens four MaybeSources into a single Flowable, without any transformation.
+ * Flattens four {@link MaybeSource}s into a single {@link Flowable}, without any transformation.
*
*
*
- * You can combine items emitted by multiple MaybeSources so that they appear as a single Flowable, by using
+ * You can combine items emitted by multiple {@code MaybeSource}s so that they appear as a single {@code Flowable}, by using
* the {@code merge} method.
*
* - Backpressure:
@@ -1215,13 +1240,13 @@ public static Flowable merge(
* - Scheduler:
* - {@code merge} does not operate by default on a particular {@link Scheduler}.
* - Error handling:
- * - If any of the source {@code MaybeSource}s signal a {@code Throwable} via {@code onError}, the resulting
+ *
- If any of the source {@code MaybeSource}s signal a {@link Throwable} via {@code onError}, the resulting
* {@code Flowable} terminates with that {@code Throwable} and all other source {@code MaybeSource}s are disposed.
* If more than one {@code MaybeSource} signals an error, the resulting {@code Flowable} may terminate with the
* first one's error or, depending on the concurrency of the sources, may terminate with a
- * {@code CompositeException} containing two or more of the various error signals.
+ * {@link CompositeException} containing two or more of the various error signals.
* {@code Throwable}s that didn't make into the composite will be sent (individually) to the global error handler via
- * {@link RxJavaPlugins#onError(Throwable)} method as {@code UndeliverableException} errors. Similarly, {@code Throwable}s
+ * {@link RxJavaPlugins#onError(Throwable)} method as {@link UndeliverableException} errors. Similarly, {@code Throwable}s
* signaled by source(s) after the returned {@code Flowable} has been cancelled or terminated with a
* (composite) error will be sent to the same global error handler.
* Use {@link #mergeDelayError(MaybeSource, MaybeSource, MaybeSource, MaybeSource)} to merge sources and terminate only when all source {@code MaybeSource}s
@@ -1231,14 +1256,15 @@ public static Flowable merge(
*
* @param the common value type
* @param source1
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source2
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source3
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source4
- * a MaybeSource to be merged
- * @return a Flowable that emits all of the items emitted by the source MaybeSources
+ * a {@code MaybeSource} to be merged
+ * @return a {@code Flowable} that emits all of the items emitted by the source {@code MaybeSource}s
+ * @throws NullPointerException if {@code source1}, {@code source2}, {@code source3} or {@code source4} is {@code null}
* @see ReactiveX operators documentation: Merge
* @see #mergeDelayError(MaybeSource, MaybeSource, MaybeSource, MaybeSource)
*/
@@ -1258,21 +1284,21 @@ public static Flowable merge(
}
/**
- * Merges an array sequence of MaybeSource instances into a single Flowable sequence,
- * running all MaybeSources at once.
+ * Merges an array sequence of {@link MaybeSource} instances into a single {@link Flowable} sequence,
+ * running all {@code MaybeSource}s at once.
*
* - Backpressure:
* - The operator honors backpressure from downstream.
* - Scheduler:
* - {@code mergeArray} does not operate by default on a particular {@link Scheduler}.
* - Error handling:
- * - If any of the source {@code MaybeSource}s signal a {@code Throwable} via {@code onError}, the resulting
+ *
- If any of the source {@code MaybeSource}s signal a {@link Throwable} via {@code onError}, the resulting
* {@code Flowable} terminates with that {@code Throwable} and all other source {@code MaybeSource}s are disposed.
* If more than one {@code MaybeSource} signals an error, the resulting {@code Flowable} may terminate with the
* first one's error or, depending on the concurrency of the sources, may terminate with a
- * {@code CompositeException} containing two or more of the various error signals.
+ * {@link CompositeException} containing two or more of the various error signals.
* {@code Throwable}s that didn't make into the composite will be sent (individually) to the global error handler via
- * {@link RxJavaPlugins#onError(Throwable)} method as {@code UndeliverableException} errors. Similarly, {@code Throwable}s
+ * {@link RxJavaPlugins#onError(Throwable)} method as {@link UndeliverableException} errors. Similarly, {@code Throwable}s
* signaled by source(s) after the returned {@code Flowable} has been cancelled or terminated with a
* (composite) error will be sent to the same global error handler.
* Use {@link #mergeArrayDelayError(MaybeSource...)} to merge sources and terminate only when all source {@code MaybeSource}s
@@ -1280,8 +1306,9 @@ public static Flowable merge(
*
*
* @param the common and resulting value type
- * @param sources the array sequence of MaybeSource sources
- * @return the new Flowable instance
+ * @param sources the array sequence of {@code MaybeSource} sources
+ * @return the new {@code Flowable} instance
+ * @throws NullPointerException if {@code sources} is {@code null}
* @see #mergeArrayDelayError(MaybeSource...)
*/
@BackpressureSupport(BackpressureKind.FULL)
@@ -1303,18 +1330,18 @@ public static Flowable mergeArray(MaybeSource extends T>... sources) {
}
/**
- * Flattens an array of MaybeSources into one Flowable, in a way that allows a Subscriber to receive all
- * successfully emitted items from each of the source MaybeSources without being interrupted by an error
+ * Flattens an array of {@link MaybeSource}s into one {@link Flowable}, in a way that allows a subscriber to receive all
+ * successfully emitted items from each of the source {@code MaybeSource}s without being interrupted by an error
* notification from one of them.
*
- * This behaves like {@link #merge(Publisher)} except that if any of the merged MaybeSources notify of an
+ * This behaves like {@link #merge(Publisher)} except that if any of the merged {@code MaybeSource}s notify of an
* error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from propagating that
- * error notification until all of the merged MaybeSources have finished emitting items.
+ * error notification until all of the merged {@code MaybeSource}s have finished emitting items.
*
*
*
- * Even if multiple merged MaybeSources send {@code onError} notifications, {@code mergeDelayError} will only
- * invoke the {@code onError} method of its Subscribers once.
+ * Even if multiple merged {@code MaybeSource}s send {@code onError} notifications, {@code mergeDelayError} will only
+ * invoke the {@code onError} method of its subscribers once.
*
* - Backpressure:
* - The operator honors backpressure from downstream.
@@ -1324,9 +1351,10 @@ public static Flowable mergeArray(MaybeSource extends T>... sources) {
*
* @param the common element base type
* @param sources
- * the Iterable of MaybeSources
- * @return a Flowable that emits items that are the result of flattening the items emitted by the
- * MaybeSources in the Iterable
+ * the array of {@code MaybeSource}s
+ * @return a {@code Flowable} that emits items that are the result of flattening the items emitted by the
+ * {@code MaybeSource}s in the array
+ * @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@SuppressWarnings({ "unchecked", "rawtypes" })
@@ -1343,18 +1371,18 @@ public static Flowable mergeArrayDelayError(@NonNull MaybeSource extend
}
/**
- * Flattens an Iterable of MaybeSources into one Flowable, in a way that allows a Subscriber to receive all
- * successfully emitted items from each of the source MaybeSources without being interrupted by an error
+ * Flattens an {@link Iterable} sequence of {@link MaybeSource}s into one {@link Flowable}, in a way that allows a subscriber to receive all
+ * successfully emitted items from each of the source {@code MaybeSource}s without being interrupted by an error
* notification from one of them.
*
- * This behaves like {@link #merge(Publisher)} except that if any of the merged MaybeSources notify of an
+ * This behaves like {@link #merge(Publisher)} except that if any of the merged {@code MaybeSource}s notify of an
* error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from propagating that
- * error notification until all of the merged MaybeSources have finished emitting items.
+ * error notification until all of the merged {@code MaybeSource}s have finished emitting items.
*
*
*
- * Even if multiple merged MaybeSources send {@code onError} notifications, {@code mergeDelayError} will only
- * invoke the {@code onError} method of its Subscribers once.
+ * Even if multiple merged {@code MaybeSource}s send {@code onError} notifications, {@code mergeDelayError} will only
+ * invoke the {@code onError} method of its subscribers once.
*
* - Backpressure:
* - The operator honors backpressure from downstream.
@@ -1364,9 +1392,10 @@ public static Flowable mergeArrayDelayError(@NonNull MaybeSource extend
*
* @param the common element base type
* @param sources
- * the Iterable of MaybeSources
- * @return a Flowable that emits items that are the result of flattening the items emitted by the
- * MaybeSources in the Iterable
+ * the {@code Iterable} of {@code MaybeSource}s
+ * @return a {@code Flowable} that emits items that are the result of flattening the items emitted by the
+ * {@code MaybeSource}s in the {@code Iterable}
+ * @throws NullPointerException if {@code sources} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@SuppressWarnings({ "unchecked", "rawtypes" })
@@ -1379,18 +1408,18 @@ public static Flowable mergeDelayError(@NonNull Iterable extends MaybeS
}
/**
- * Flattens a Publisher that emits MaybeSources into one Publisher, in a way that allows a Subscriber to
- * receive all successfully emitted items from all of the source MaybeSources without being interrupted by
- * an error notification from one of them or even the main Publisher.
+ * Flattens a {@link Publisher} that emits {@link MaybeSource}s into one {@link Flowable}, in a way that allows a subscriber to
+ * receive all successfully emitted items from all of the source {@code MaybeSource}s without being interrupted by
+ * an error notification from one of them or even the main {@code Publisher}.
*
- * This behaves like {@link #merge(Publisher)} except that if any of the merged MaybeSources notify of an
+ * This behaves like {@link #merge(Publisher)} except that if any of the merged {@code MaybeSource}s notify of an
* error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from propagating that
- * error notification until all of the merged MaybeSources and the main Publisher have finished emitting items.
+ * error notification until all of the merged {@code MaybeSource}s and the main {@code Publisher} have finished emitting items.
*
*
*
- * Even if multiple merged Publishers send {@code onError} notifications, {@code mergeDelayError} will only
- * invoke the {@code onError} method of its Subscribers once.
+ * Even if multiple merged {@code MaybeSource}s send {@code onError} notifications, {@code mergeDelayError} will only
+ * invoke the {@code onError} method of its subscribers once.
*
* - Backpressure:
* - The operator honors backpressure from downstream. The outer {@code Publisher} is consumed
@@ -1401,9 +1430,9 @@ public static Flowable mergeDelayError(@NonNull Iterable extends MaybeS
*
* @param the common element base type
* @param sources
- * a Publisher that emits MaybeSources
- * @return a Flowable that emits all of the items emitted by the Publishers emitted by the
- * {@code source} Publisher
+ * a {@code Publisher} that emits {@code MaybeSource}s
+ * @return a {@code Flowable} that emits all of the items emitted by the {@code MaybeSource}s emitted by the
+ * {@code source} {@code Publisher}
* @see ReactiveX operators documentation: Merge
*/
@BackpressureSupport(BackpressureKind.FULL)
@@ -1415,18 +1444,18 @@ public static Flowable mergeDelayError(@NonNull Publisher extends Maybe
}
/**
- * Flattens a Publisher that emits MaybeSources into one Publisher, in a way that allows a Subscriber to
- * receive all successfully emitted items from all of the source MaybeSources without being interrupted by
- * an error notification from one of them or even the main Publisher as well as limiting the total number of active MaybeSources.
+ * Flattens a {@link Publisher} that emits {@link MaybeSource}s into one {@link Flowable}, in a way that allows a subscriber to
+ * receive all successfully emitted items from all of the source {@code MaybeSource}s without being interrupted by
+ * an error notification from one of them or even the main {@code Publisher} as well as limiting the total number of active {@code MaybeSource}s.
*
- * This behaves like {@link #merge(Publisher, int)} except that if any of the merged MaybeSources notify of an
+ * This behaves like {@link #merge(Publisher, int)} except that if any of the merged {@code MaybeSource}s notify of an
* error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from propagating that
- * error notification until all of the merged MaybeSources and the main Publisher have finished emitting items.
+ * error notification until all of the merged {@code MaybeSource}s and the main {@code Publisher} have finished emitting items.
*
*
*
- * Even if multiple merged Publishers send {@code onError} notifications, {@code mergeDelayError} will only
- * invoke the {@code onError} method of its Subscribers once.
+ * Even if multiple merged {@code MaybeSource}s send {@code onError} notifications, {@code mergeDelayError} will only
+ * invoke the {@code onError} method of its subscribers once.
*
* - Backpressure:
* - The operator honors backpressure from downstream. The outer {@code Publisher} is consumed
@@ -1437,10 +1466,12 @@ public static Flowable mergeDelayError(@NonNull Publisher extends Maybe
*
History: 2.1.9 - experimental
* @param the common element base type
* @param sources
- * a Publisher that emits MaybeSources
- * @param maxConcurrency the maximum number of active inner MaybeSources to be merged at a time
- * @return a Flowable that emits all of the items emitted by the Publishers emitted by the
- * {@code source} Publisher
+ * a {@code Publisher} that emits {@code MaybeSource}s
+ * @param maxConcurrency the maximum number of active inner {@code MaybeSource}s to be merged at a time
+ * @return a {@code Flowable} that emits all of the items emitted by the {@code MaybeSource}s emitted by the
+ * {@code source} {@code Publisher}
+ * @throws NullPointerException if {@code sources} is {@code null}
+ * @throws IllegalArgumentException if {@code maxConcurrency} is non-positive
* @see ReactiveX operators documentation: Merge
* @since 2.2
*/
@@ -1456,18 +1487,18 @@ public static Flowable mergeDelayError(@NonNull Publisher extends Maybe
}
/**
- * Flattens two MaybeSources into one Flowable, in a way that allows a Subscriber to receive all
- * successfully emitted items from each of the source MaybeSources without being interrupted by an error
+ * Flattens two {@link MaybeSource}s into one {@link Flowable}, in a way that allows a subscriber to receive all
+ * successfully emitted items from each of the source {@code MaybeSource}s without being interrupted by an error
* notification from one of them.
*
- * This behaves like {@link #merge(MaybeSource, MaybeSource)} except that if any of the merged MaybeSources
+ * This behaves like {@link #merge(MaybeSource, MaybeSource)} except that if any of the merged {@code MaybeSource}s
* notify of an error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from
- * propagating that error notification until all of the merged MaybeSources have finished emitting items.
+ * propagating that error notification until all of the merged {@code MaybeSource}s have finished emitting items.
*
*
*
- * Even if both merged MaybeSources send {@code onError} notifications, {@code mergeDelayError} will only
- * invoke the {@code onError} method of its Subscribers once.
+ * Even if both merged {@code MaybeSource}s send {@code onError} notifications, {@code mergeDelayError} will only
+ * invoke the {@code onError} method of its subscribers once.
*
* - Backpressure:
* - The operator honors backpressure from downstream.
@@ -1477,10 +1508,11 @@ public static Flowable mergeDelayError(@NonNull Publisher extends Maybe
*
* @param the common element base type
* @param source1
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source2
- * a MaybeSource to be merged
- * @return a Flowable that emits all of the items that are emitted by the two source MaybeSources
+ * a {@code MaybeSource} to be merged
+ * @return a {@code Flowable} that emits all of the items that are emitted by the two source {@code MaybeSource}s
+ * @throws NullPointerException if {@code source1} or {@code source2} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@BackpressureSupport(BackpressureKind.FULL)
@@ -1494,19 +1526,19 @@ public static Flowable mergeDelayError(@NonNull MaybeSource extends T>
}
/**
- * Flattens three MaybeSource into one Flowable, in a way that allows a Subscriber to receive all
- * successfully emitted items from all of the source MaybeSources without being interrupted by an error
+ * Flattens three {@link MaybeSource} into one {@link Flowable}, in a way that allows a subscriber to receive all
+ * successfully emitted items from all of the source {@code MaybeSource}s without being interrupted by an error
* notification from one of them.
*
* This behaves like {@link #merge(MaybeSource, MaybeSource, MaybeSource)} except that if any of the merged
- * MaybeSources notify of an error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain
- * from propagating that error notification until all of the merged MaybeSources have finished emitting
+ * {@code MaybeSource}s notify of an error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain
+ * from propagating that error notification until all of the merged {@code MaybeSource}s have finished emitting
* items.
*
*
*
- * Even if multiple merged MaybeSources send {@code onError} notifications, {@code mergeDelayError} will only
- * invoke the {@code onError} method of its Subscribers once.
+ * Even if multiple merged {@code MaybeSource}s send {@code onError} notifications, {@code mergeDelayError} will only
+ * invoke the {@code onError} method of its subscribers once.
*
* - Backpressure:
* - The operator honors backpressure from downstream.
@@ -1516,12 +1548,13 @@ public static Flowable mergeDelayError(@NonNull MaybeSource extends T>
*
* @param the common element base type
* @param source1
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source2
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source3
- * a MaybeSource to be merged
- * @return a Flowable that emits all of the items that are emitted by the source MaybeSources
+ * a {@code MaybeSource} to be merged
+ * @return a {@code Flowable} that emits all of the items that are emitted by the source {@code MaybeSource}s
+ * @throws NullPointerException if {@code source1}, {@code source2} or {@code source3} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@BackpressureSupport(BackpressureKind.FULL)
@@ -1537,19 +1570,19 @@ public static Flowable mergeDelayError(@NonNull MaybeSource extends T>
}
/**
- * Flattens four MaybeSources into one Flowable, in a way that allows a Subscriber to receive all
- * successfully emitted items from all of the source MaybeSources without being interrupted by an error
+ * Flattens four {@link MaybeSource}s into one {@link Flowable}, in a way that allows a subscriber to receive all
+ * successfully emitted items from all of the source {@code MaybeSource}s without being interrupted by an error
* notification from one of them.
*
* This behaves like {@link #merge(MaybeSource, MaybeSource, MaybeSource, MaybeSource)} except that if any of
- * the merged MaybeSources notify of an error via {@link Subscriber#onError onError}, {@code mergeDelayError}
- * will refrain from propagating that error notification until all of the merged MaybeSources have finished
+ * the merged {@code MaybeSource}s notify of an error via {@link Subscriber#onError onError}, {@code mergeDelayError}
+ * will refrain from propagating that error notification until all of the merged {@code MaybeSource}s have finished
* emitting items.
*
*
*
- * Even if multiple merged MaybeSources send {@code onError} notifications, {@code mergeDelayError} will only
- * invoke the {@code onError} method of its Subscribers once.
+ * Even if multiple merged {@code MaybeSource}s send {@code onError} notifications, {@code mergeDelayError} will only
+ * invoke the {@code onError} method of its subscribers once.
*
* - Backpressure:
* - The operator honors backpressure from downstream.
@@ -1559,14 +1592,15 @@ public static Flowable mergeDelayError(@NonNull MaybeSource extends T>
*
* @param the common element base type
* @param source1
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source2
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source3
- * a MaybeSource to be merged
+ * a {@code MaybeSource} to be merged
* @param source4
- * a MaybeSource to be merged
- * @return a Flowable that emits all of the items that are emitted by the source MaybeSources
+ * a {@code MaybeSource} to be merged
+ * @return a {@code Flowable} that emits all of the items that are emitted by the source {@code MaybeSource}s
+ * @throws NullPointerException if {@code source1}, {@code source2}, {@code source3} or {@code source4} is {@code null}
* @see ReactiveX operators documentation: Merge
*/
@BackpressureSupport(BackpressureKind.FULL)
@@ -1584,19 +1618,19 @@ public static Flowable mergeDelayError(
}
/**
- * Returns a Maybe that never sends any items or notifications to a {@link MaybeObserver}.
+ * Returns a {@code Maybe} that never sends any items or notifications to a {@link MaybeObserver}.
*
*
*
- * This Maybe is useful primarily for testing purposes.
+ * This {@code Maybe} is useful primarily for testing purposes.
*
* - Scheduler:
* - {@code never} does not operate by default on a particular {@link Scheduler}.
*
*
* @param
- * the type of items (not) emitted by the Maybe
- * @return a Maybe that never emits any items or sends any notifications to a {@link MaybeObserver}
+ * the type of items (not) emitted by the {@code Maybe}
+ * @return a {@code Maybe} that never emits any items or sends any notifications to a {@code MaybeObserver}
* @see ReactiveX operators documentation: Never
*/
@CheckReturnValue
@@ -1608,8 +1642,8 @@ public static Maybe never() {
}
/**
- * Returns a Single that emits a Boolean value that indicates whether two MaybeSource sequences are the
- * same by comparing the items emitted by each MaybeSource pairwise.
+ * Returns a {@link Single} that emits a {@link Boolean} value that indicates whether two {@link MaybeSource} sequences are the
+ * same by comparing the items emitted by each {@code MaybeSource} pairwise.
*
*
*
@@ -1618,12 +1652,12 @@ public static Maybe never() {
*
*
* @param source1
- * the first MaybeSource to compare
+ * the first {@code MaybeSource} to compare
* @param source2
- * the second MaybeSource to compare
+ * the second {@code MaybeSource} to compare
* @param
- * the type of items emitted by each MaybeSource
- * @return a Single that emits a Boolean value that indicates whether the two sequences are the same
+ * the type of items emitted by each {@code MaybeSource}
+ * @return a {@code Single} that emits a {@code Boolean} value that indicates whether the two sequences are the same
* @see ReactiveX operators documentation: SequenceEqual
*/
@CheckReturnValue
@@ -1634,8 +1668,8 @@ public static Single sequenceEqual(@NonNull MaybeSource extends T
}
/**
- * Returns a Single that emits a Boolean value that indicates whether two MaybeSources are the
- * same by comparing the items emitted by each MaybeSource pairwise based on the results of a specified
+ * Returns a {@link Single} that emits a {@link Boolean} value that indicates whether two {@link MaybeSource}s are the
+ * same by comparing the items emitted by each {@code MaybeSource} pairwise based on the results of a specified
* equality function.
*
*
@@ -1645,15 +1679,16 @@ public static Single sequenceEqual(@NonNull MaybeSource extends T
*
*
* @param source1
- * the first MaybeSource to compare
+ * the first {@code MaybeSource} to compare
* @param source2
- * the second MaybeSource to compare
+ * the second {@code MaybeSource} to compare
* @param isEqual
- * a function used to compare items emitted by each MaybeSource
+ * a function used to compare items emitted by each {@code MaybeSource}
* @param
- * the type of items emitted by each MaybeSource
- * @return a Single that emits a Boolean value that indicates whether the two MaybeSource sequences
+ * the type of items emitted by each {@code MaybeSource}
+ * @return a {@code Single} that emits a {@code Boolean} value that indicates whether the two {@code MaybeSource} sequences
* are the same according to the specified function
+ * @throws NullPointerException if {@code source1}, {@code source2} or {@code isEqual} is {@code null}
* @see ReactiveX operators documentation: SequenceEqual
*/
@CheckReturnValue
@@ -1668,7 +1703,7 @@ public static Single sequenceEqual(@NonNull MaybeSource extends T
}
/**
- * Returns a Maybe that emits {@code 0L} after a specified delay.
+ * Returns a {@code Maybe} that emits {@code 0L} after a specified delay.
*
*
*
@@ -1680,7 +1715,7 @@ public static Single sequenceEqual(@NonNull MaybeSource extends T
* the initial delay before emitting a single {@code 0L}
* @param unit
* time units to use for {@code delay}
- * @return a Maybe that emits {@code 0L} after a specified delay
+ * @return a {@code Maybe} that emits {@code 0L} after a specified delay
* @see ReactiveX operators documentation: Timer
*/
@CheckReturnValue
@@ -1691,12 +1726,12 @@ public static Maybe timer(long delay, @NonNull TimeUnit unit) {
}
/**
- * Returns a Maybe that emits {@code 0L} after a specified delay on a specified Scheduler.
+ * Returns a {@code Maybe} that emits {@code 0L} after a specified delay on a specified {@link Scheduler}.
*
*
*
* - Scheduler:
- * - You specify which {@link Scheduler} this operator will use.
+ * - You specify which {@code Scheduler} this operator will use.
*
*
* @param delay
@@ -1704,8 +1739,9 @@ public static Maybe timer(long delay, @NonNull TimeUnit unit) {
* @param unit
* time units to use for {@code delay}
* @param scheduler
- * the {@link Scheduler} to use for scheduling the item
- * @return a Maybe that emits {@code 0L} after a specified delay, on a specified Scheduler
+ * the {@code Scheduler} to use for scheduling the item
+ * @return a {@code Maybe} that emits {@code 0L} after a specified delay, on a specified {@code Scheduler}
+ * @throws NullPointerException if {@code unit} or {@code scheduler} is {@code null}
* @see ReactiveX operators documentation: Timer
*/
@CheckReturnValue
@@ -1719,15 +1755,15 @@ public static Maybe timer(long delay, @NonNull TimeUnit unit, @NonNull Sch
}
/**
- * Advanced use only: creates a Maybe instance without
- * any safeguards by using a callback that is called with a MaybeObserver.
+ * Advanced use only: creates a {@code Maybe} instance without
+ * any safeguards by using a callback that is called with a {@link MaybeObserver}.
*
* - Scheduler:
* - {@code unsafeCreate} does not operate by default on a particular {@link Scheduler}.
*
* @param the value type
- * @param onSubscribe the function that is called with the subscribing MaybeObserver
- * @return the new Maybe instance
+ * @param onSubscribe the function that is called with the subscribing {@code MaybeObserver}
+ * @return the new {@code Maybe} instance
*/
@CheckReturnValue
@NonNull
@@ -1741,8 +1777,8 @@ public static Maybe unsafeCreate(@NonNull MaybeSource onSubscribe) {
}
/**
- * Constructs a Maybe that creates a dependent resource object which is disposed of when the
- * upstream terminates or the downstream calls dispose().
+ * Constructs a {@code Maybe} that creates a dependent resource object which is disposed of when the
+ * generated {@link MaybeSource} terminates or the downstream calls dispose().
*
*
*
@@ -1750,15 +1786,15 @@ public static Maybe unsafeCreate(@NonNull MaybeSource onSubscribe) {
* - {@code using} does not operate by default on a particular {@link Scheduler}.
*
*
- * @param the element type of the generated MaybeSource
+ * @param the element type of the generated {@code MaybeSource}
* @param the type of the resource associated with the output sequence
* @param resourceSupplier
- * the factory function to create a resource object that depends on the Maybe
+ * the factory function to create a resource object that depends on the {@code Maybe}
* @param sourceSupplier
- * the factory function to create a MaybeSource
+ * the factory function to create a {@code MaybeSource}
* @param resourceDisposer
* the function that will dispose of the resource
- * @return the Maybe whose lifetime controls the lifetime of the dependent resource object
+ * @return the {@code Maybe} whose lifetime controls the lifetime of the dependent resource object
* @see ReactiveX operators documentation: Using
*/
@CheckReturnValue
@@ -1771,24 +1807,24 @@ public static Maybe using(@NonNull Supplier extends D> resourceSuppl
}
/**
- * Constructs a Maybe that creates a dependent resource object which is disposed of just before
- * termination if you have set {@code disposeEagerly} to {@code true} and a downstream dispose() does not occur
- * before termination. Otherwise resource disposal will occur on call to dispose(). Eager disposal is
- * particularly appropriate for a synchronous Maybe that reuses resources. {@code disposeAction} will
- * only be called once per subscription.
+ * Constructs a {@code Maybe} that creates a dependent resource object which is disposed first ({code eager == true})
+ * when the generated {@link MaybeSource} terminates or the downstream disposes; or after ({code eager == false}).
*
*
+ *
+ * Eager disposal is particularly appropriate for a synchronous {@code Maybe} that reuses resources. {@code disposeAction} will
+ * only be called once per subscription.
*
* - Scheduler:
* - {@code using} does not operate by default on a particular {@link Scheduler}.
*
*
- * @param the element type of the generated MaybeSource
+ * @param the element type of the generated {@code MaybeSource}
* @param the type of the resource associated with the output sequence
* @param resourceSupplier
- * the factory function to create a resource object that depends on the Maybe
+ * the factory function to create a resource object that depends on the {@code Maybe}
* @param sourceSupplier
- * the factory function to create a MaybeSource
+ * the factory function to create a {@code MaybeSource}
* @param resourceDisposer
* the function that will dispose of the resource
* @param eager
@@ -1796,7 +1832,8 @@ public static Maybe using(@NonNull Supplier extends D> resourceSuppl
* or just before the emission of a terminal event ({@code onSuccess}, {@code onComplete} or {@code onError}).
* If {@code false} the resource disposal will happen either on a {@code dispose()} call after the upstream is disposed
* or just after the emission of a terminal event ({@code onSuccess}, {@code onComplete} or {@code onError}).
- * @return the Maybe whose lifetime controls the lifetime of the dependent resource object
+ * @return the {@code Maybe} whose lifetime controls the lifetime of the dependent resource object
+ * @throws NullPointerException if {@code resourceSupplier}, {@code sourceSupplier} or {@code resourceDisposer} is {@code null}
* @see ReactiveX operators documentation: Using
*/
@CheckReturnValue
@@ -1812,7 +1849,7 @@ public static Maybe using(@NonNull Supplier extends D> resourceSuppl
}
/**
- * Wraps a MaybeSource instance into a new Maybe instance if not already a Maybe
+ * Wraps a {@link MaybeSource} instance into a new {@code Maybe} instance if not already a {@code Maybe}
* instance.
*
* - Scheduler:
@@ -1820,7 +1857,7 @@ public static Maybe using(@NonNull Supplier extends D> resourceSuppl
*
* @param the value type
* @param source the source to wrap
- * @return the Maybe wrapper or the source cast to Maybe (if possible)
+ * @return the {@code Maybe} wrapper or the source cast to {@code Maybe} (if possible)
*/
@CheckReturnValue
@NonNull
@@ -1834,16 +1871,16 @@ public static Maybe wrap(@NonNull MaybeSource source) {
}
/**
- * Returns a Maybe that emits the results of a specified combiner function applied to combinations of
- * items emitted, in sequence, by an Iterable of other MaybeSources.
+ * Returns a {@code Maybe} that emits the results of a specified combiner function applied to combinations of
+ * items emitted, in sequence, by an {@link Iterable} of other {@link MaybeSource}s.
*
*
*
* 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}.
*
- * This operator terminates eagerly if any of the source MaybeSources signal an onError or onComplete. This
+ * This operator terminates eagerly if any of the source {@code MaybeSource}s signal an {@code onError} or {@code onComplete}. This
* also means it is possible some sources may not get subscribed to at all.
*
* - Scheduler:
@@ -1853,11 +1890,12 @@ public static Maybe wrap(@NonNull MaybeSource source) {
* @param the common value type
* @param the zipped result type
* @param sources
- * an Iterable of source MaybeSources
+ * an {@code Iterable} of source {@code MaybeSource}s
* @param zipper
- * a function that, when applied to an item emitted by each of the source MaybeSources, results in
- * an item that will be emitted by the resulting Maybe
- * @return a Maybe that emits the zipped results
+ * a function that, when applied to an item emitted by each of the source {@code MaybeSource}s, results in
+ * an item that will be emitted by the resulting {@code Maybe}
+ * @return a {@code Maybe} that emits the zipped results
+ * @throws NullPointerException if {@code zipper} or {@code sources} is {@code null}
* @see ReactiveX operators documentation: Zip
*/
@CheckReturnValue
@@ -1870,12 +1908,12 @@ public static Maybe zip(@NonNull Iterable extends MaybeSource exte
}
/**
- * Returns a Maybe that emits the results of a specified combiner function applied to combinations of
- * two items emitted, in sequence, by two other MaybeSources.
+ * Returns a {@code Maybe} that emits the results of a specified combiner function applied to combinations of
+ * two items emitted, in sequence, by two other {@link MaybeSource}s.
*
*
*
- * This operator terminates eagerly if any of the source MaybeSources signal an onError or onComplete. This
+ * This operator terminates eagerly if any of the source {@code MaybeSource}s signal an {@code onError} or {@code onComplete}. This
* also means it is possible some sources may not get subscribed to at all.
*
* - Scheduler:
@@ -1886,13 +1924,14 @@ public static Maybe zip(@NonNull Iterable extends MaybeSource exte
* @param the value type of the second source
* @param the zipped result type
* @param source1
- * the first source MaybeSource
+ * the first source {@code MaybeSource}
* @param source2
- * a second source MaybeSource
+ * a second source {@code MaybeSource}
* @param zipper
- * a function that, when applied to an item emitted by each of the source MaybeSources, results
- * in an item that will be emitted by the resulting Maybe
- * @return a Maybe that emits the zipped results
+ * a function that, when applied to an item emitted by each of the source {@code MaybeSource}s, results
+ * in an item that will be emitted by the resulting {@code Maybe}
+ * @return a {@code Maybe} that emits the zipped results
+ * @throws NullPointerException if {@code source1}, {@code source2} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
*/
@CheckReturnValue
@@ -1908,12 +1947,12 @@ public static Maybe zip(
}
/**
- * Returns a Maybe that emits the results of a specified combiner function applied to combinations of
- * three items emitted, in sequence, by three other MaybeSources.
+ * Returns a {@code Maybe} that emits the results of a specified combiner function applied to combinations of
+ * three items emitted, in sequence, by three other {@link MaybeSource}s.
*
*
*
- * This operator terminates eagerly if any of the source MaybeSources signal an onError or onComplete. This
+ * This operator terminates eagerly if any of the source {@code MaybeSource}s signal an {@code onError} or {@code onComplete}. This
* also means it is possible some sources may not get subscribed to at all.
*
* - Scheduler:
@@ -1925,15 +1964,16 @@ public static Maybe zip(
* @param the value type of the third source
* @param the zipped result type
* @param source1
- * the first source MaybeSource
+ * the first source {@code MaybeSource}
* @param source2
- * a second source MaybeSource
+ * a second source {@code MaybeSource}
* @param source3
- * a third source MaybeSource
+ * a third source {@code MaybeSource}
* @param zipper
- * a function that, when applied to an item emitted by each of the source MaybeSources, results in
- * an item that will be emitted by the resulting Maybe
- * @return a Maybe that emits the zipped results
+ * a function that, when applied to an item emitted by each of the source {@code MaybeSource}s, results in
+ * an item that will be emitted by the resulting {@code Maybe}
+ * @return a {@code Maybe} that emits the zipped results
+ * @throws NullPointerException if {@code source1}, {@code source2}, {@code source3} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
*/
@CheckReturnValue
@@ -1950,12 +1990,12 @@ public static Maybe zip(
}
/**
- * Returns a Maybe that emits the results of a specified combiner function applied to combinations of
- * four items emitted, in sequence, by four other MaybeSources.
+ * Returns a {@code Maybe} that emits the results of a specified combiner function applied to combinations of
+ * four items emitted, in sequence, by four other {@link MaybeSource}s.
*
*
*
- * This operator terminates eagerly if any of the source MaybeSources signal an onError or onComplete. This
+ * This operator terminates eagerly if any of the source {@code MaybeSource}s signal an {@code onError} or {@code onComplete}. This
* also means it is possible some sources may not get subscribed to at all.
*
* - Scheduler:
@@ -1968,17 +2008,19 @@ public static Maybe zip(
* @param the value type of the fourth source
* @param the zipped result type
* @param source1
- * the first source MaybeSource
+ * the first source {@code MaybeSource}
* @param source2
- * a second source MaybeSource
+ * a second source {@code MaybeSource}
* @param source3
- * a third source MaybeSource
+ * a third source {@code MaybeSource}
* @param source4
- * a fourth source MaybeSource
+ * a fourth source {@code MaybeSource}
* @param zipper
- * a function that, when applied to an item emitted by each of the source MaybeSources, results in
- * an item that will be emitted by the resulting Maybe
- * @return a Maybe that emits the zipped results
+ * a function that, when applied to an item emitted by each of the source {@code MaybeSource}s, results in
+ * an item that will be emitted by the resulting {@code Maybe}
+ * @return a {@code Maybe} that emits the zipped results
+ * @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
+ * {@code source4} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
*/
@CheckReturnValue
@@ -1997,12 +2039,12 @@ public static Maybe zip(
}
/**
- * Returns a Maybe that emits the results of a specified combiner function applied to combinations of
- * five items emitted, in sequence, by five other MaybeSources.
+ * Returns a {@code Maybe} that emits the results of a specified combiner function applied to combinations of
+ * five items emitted, in sequence, by five other {@link MaybeSource}s.
*
*
*
- * This operator terminates eagerly if any of the source MaybeSources signal an onError or onComplete. This
+ * This operator terminates eagerly if any of the source {@code MaybeSource}s signal an {@code onError} or {@code onComplete}. This
* also means it is possible some sources may not get subscribed to at all.
*
* - Scheduler:
@@ -2016,19 +2058,21 @@ public static Maybe zip(
* @param the value type of the fifth source
* @param the zipped result type
* @param source1
- * the first source MaybeSource
+ * the first source {@code MaybeSource}
* @param source2
- * a second source MaybeSource
+ * a second source {@code MaybeSource}
* @param source3
- * a third source MaybeSource
+ * a third source {@code MaybeSource}
* @param source4
- * a fourth source MaybeSource
+ * a fourth source {@code MaybeSource}
* @param source5
- * a fifth source MaybeSource
+ * a fifth source {@code MaybeSource}
* @param zipper
- * a function that, when applied to an item emitted by each of the source MaybeSources, results in
- * an item that will be emitted by the resulting Maybe
- * @return a Maybe that emits the zipped results
+ * a function that, when applied to an item emitted by each of the source {@code MaybeSource}s, results in
+ * an item that will be emitted by the resulting {@code Maybe}
+ * @return a {@code Maybe} that emits the zipped results
+ * @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
+ * {@code source4}, {@code source5} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
*/
@CheckReturnValue
@@ -2048,12 +2092,12 @@ public static Maybe zip(
}
/**
- * Returns a Maybe that emits the results of a specified combiner function applied to combinations of
- * six items emitted, in sequence, by six other MaybeSources.
+ * Returns a {@code Maybe} that emits the results of a specified combiner function applied to combinations of
+ * six items emitted, in sequence, by six other {@link MaybeSource}s.
*
*
*
- * This operator terminates eagerly if any of the source MaybeSources signal an onError or onComplete. This
+ * This operator terminates eagerly if any of the source {@code MaybeSource}s signal an {@code onError} or {@code onComplete}. This
* also means it is possible some sources may not get subscribed to at all.
*
* - Scheduler:
@@ -2068,21 +2112,23 @@ public static Maybe zip(
* @param the value type of the sixth source
* @param the zipped result type
* @param source1
- * the first source MaybeSource
+ * the first source {@code MaybeSource}
* @param source2
- * a second source MaybeSource
+ * a second source {@code MaybeSource}
* @param source3
- * a third source MaybeSource
+ * a third source {@code MaybeSource}
* @param source4
- * a fourth source MaybeSource
+ * a fourth source {@code MaybeSource}
* @param source5
- * a fifth source MaybeSource
+ * a fifth source {@code MaybeSource}
* @param source6
- * a sixth source MaybeSource
+ * a sixth source {@code MaybeSource}
* @param zipper
- * a function that, when applied to an item emitted by each of the source MaybeSources, results in
- * an item that will be emitted by the resulting Maybe
- * @return a Maybe that emits the zipped results
+ * a function that, when applied to an item emitted by each of the source {@code MaybeSource}s, results in
+ * an item that will be emitted by the resulting {@code Maybe}
+ * @return a {@code Maybe} that emits the zipped results
+ * @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
+ * {@code source4}, {@code source5}, {@code source6} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
*/
@CheckReturnValue
@@ -2103,12 +2149,12 @@ public static Maybe zip(
}
/**
- * Returns a Maybe that emits the results of a specified combiner function applied to combinations of
- * seven items emitted, in sequence, by seven other MaybeSources.
+ * Returns a {@code Maybe} that emits the results of a specified combiner function applied to combinations of
+ * seven items emitted, in sequence, by seven other {@link MaybeSource}s.
*
*
*
- * This operator terminates eagerly if any of the source MaybeSources signal an onError or onComplete. This
+ * This operator terminates eagerly if any of the source {@code MaybeSource}s signal an {@code onError} or {@code onComplete}. This
* also means it is possible some sources may not get subscribed to at all.
*
* - Scheduler:
@@ -2124,23 +2170,26 @@ public static Maybe zip(
* @param the value type of the seventh source
* @param the zipped result type
* @param source1
- * the first source MaybeSource
+ * the first source {@code MaybeSource}
* @param source2
- * a second source MaybeSource
+ * a second source {@code MaybeSource}
* @param source3
- * a third source MaybeSource
+ * a third source {@code MaybeSource}
* @param source4
- * a fourth source MaybeSource
+ * a fourth source {@code MaybeSource}
* @param source5
- * a fifth source MaybeSource
+ * a fifth source {@code MaybeSource}
* @param source6
- * a sixth source MaybeSource
+ * a sixth source {@code MaybeSource}
* @param source7
- * a seventh source MaybeSource
+ * a seventh source {@code MaybeSource}
* @param zipper
- * a function that, when applied to an item emitted by each of the source MaybeSources, results in
- * an item that will be emitted by the resulting Maybe
- * @return a Maybe that emits the zipped results
+ * a function that, when applied to an item emitted by each of the source {@code MaybeSource}s, results in
+ * an item that will be emitted by the resulting {@code Maybe}
+ * @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
+ * {@code source4}, {@code source5}, {@code source6},
+ * {@code source7} or {@code zipper} is {@code null}
+ * @return a {@code Maybe} that emits the zipped results
* @see ReactiveX operators documentation: Zip
*/
@CheckReturnValue
@@ -2163,12 +2212,12 @@ public static Maybe zip(
}
/**
- * Returns a Maybe that emits the results of a specified combiner function applied to combinations of
- * eight items emitted, in sequence, by eight other MaybeSources.
+ * Returns a {@code Maybe} that emits the results of a specified combiner function applied to combinations of
+ * eight items emitted, in sequence, by eight other {@link MaybeSource}s.
*
*
*
- * This operator terminates eagerly if any of the source MaybeSources signal an onError or onComplete. This
+ * This operator terminates eagerly if any of the source {@code MaybeSource}s signal an {@code onError} or {@code onComplete}. This
* also means it is possible some sources may not get subscribed to at all.
*
* - Scheduler:
@@ -2185,25 +2234,28 @@ public static Maybe zip(
* @param the value type of the eighth source
* @param the zipped result type
* @param source1
- * the first source MaybeSource
+ * the first source {@code MaybeSource}
* @param source2
- * a second source MaybeSource
+ * a second source {@code MaybeSource}
* @param source3
- * a third source MaybeSource
+ * a third source {@code MaybeSource}
* @param source4
- * a fourth source MaybeSource
+ * a fourth source {@code MaybeSource}
* @param source5
- * a fifth source MaybeSource
+ * a fifth source {@code MaybeSource}
* @param source6
- * a sixth source MaybeSource
+ * a sixth source {@code MaybeSource}
* @param source7
- * a seventh source MaybeSource
+ * a seventh source {@code MaybeSource}
* @param source8
- * an eighth source MaybeSource
+ * an eighth source {@code MaybeSource}
* @param zipper
- * a function that, when applied to an item emitted by each of the source MaybeSources, results in
- * an item that will be emitted by the resulting Maybe
- * @return a Maybe that emits the zipped results
+ * a function that, when applied to an item emitted by each of the source {@code MaybeSource}s, results in
+ * an item that will be emitted by the resulting {@code Maybe}
+ * @return a {@code Maybe} that emits the zipped results
+ * @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}
* @see ReactiveX operators documentation: Zip
*/
@CheckReturnValue
@@ -2227,12 +2279,12 @@ public static Maybe zip(
}
/**
- * Returns a Maybe that emits the results of a specified combiner function applied to combinations of
- * nine items emitted, in sequence, by nine other MaybeSources.
+ * Returns a {@code Maybe} that emits the results of a specified combiner function applied to combinations of
+ * nine items emitted, in sequence, by nine other {@link MaybeSource}s.
*
*
*
- * This operator terminates eagerly if any of the source MaybeSources signal an onError or onComplete. This
+ * This operator terminates eagerly if any of the source {@code MaybeSource}s signal an {@code onError} or {@code onComplete}. This
* also means it is possible some sources may not get subscribed to at all.
*
* - Scheduler:
@@ -2249,27 +2301,30 @@ public static Maybe zip(
* @param the value type of the ninth source
* @param the zipped result type
* @param source1
- * the first source MaybeSource
+ * the first source {@code MaybeSource}
* @param source2
- * a second source MaybeSource
+ * a second source {@code MaybeSource}
* @param source3
- * a third source MaybeSource
+ * a third source {@code MaybeSource}
* @param source4
- * a fourth source MaybeSource
+ * a fourth source {@code MaybeSource}
* @param source5
- * a fifth source MaybeSource
+ * a fifth source {@code MaybeSource}
* @param source6
- * a sixth source MaybeSource
+ * a sixth source {@code MaybeSource}
* @param source7
- * a seventh source MaybeSource
+ * a seventh source {@code MaybeSource}
* @param source8
- * an eighth source MaybeSource
+ * an eighth source {@code MaybeSource}
* @param source9
- * a ninth source MaybeSource
+ * a ninth source {@code MaybeSource}
* @param zipper
- * a function that, when applied to an item emitted by each of the source MaybeSources, results in
- * an item that will be emitted by the resulting MaybeSource
- * @return a Maybe that emits the zipped results
+ * a function that, when applied to an item emitted by each of the source {@code MaybeSource}s, results in
+ * an item that will be emitted by the resulting {@code Maybe}
+ * @return a {@code Maybe} that emits the zipped results
+ * @throws NullPointerException if {@code source1}, {@code source2}, {@code source3},
+ * {@code source4}, {@code source5}, {@code source6},
+ * {@code source7}, {@code source8}, {@code source9} or {@code zipper} is {@code null}
* @see ReactiveX operators documentation: Zip
*/
@CheckReturnValue
@@ -2295,16 +2350,16 @@ public static Maybe zip(
}
/**
- * Returns a Maybe that emits the results of a specified combiner function applied to combinations of
- * items emitted, in sequence, by an array of other MaybeSources.
+ * Returns a {@code Maybe} that emits the results of a specified combiner function applied to combinations of
+ * items emitted, in sequence, by an array of other {@link MaybeSource}s.
*
* 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}.
*
*
*
- *
This operator terminates eagerly if any of the source MaybeSources signal an onError or onComplete. This
+ *
This operator terminates eagerly if any of the source {@code MaybeSource}s signal an {@code onError} or {@code onComplete}. This
* also means it is possible some sources may not get subscribed to at all.
*
* - Scheduler:
@@ -2314,11 +2369,12 @@ public static Maybe zip(
* @param