- *
+ *
*
* The documentation for this class makes use of marble diagrams. The following legend explains these diagrams: *
- *
+ *
*
* The {@code Flowable} follows the protocol *
@@ -163,7 +163,7 @@ public abstract class Flowable<@NonNull T> implements Publisher {
* Mirrors the one {@link Publisher} in an {@link Iterable} of several {@code Publisher}s that first either emits an item or sends
* a termination notification.
*
- *
+ *
*
* - Backpressure:
* - The operator itself doesn't interfere with backpressure which is determined by the winning
@@ -193,7 +193,7 @@ public static
Flowable amb(@NonNull Iterable<@NonNull ? extends Publisher
* Mirrors the one {@link Publisher} in an array of several {@code Publisher}s that first either emits an item or sends
* a termination notification.
*
- *
+ *
*
* - Backpressure:
* - The operator itself doesn't interfere with backpressure which is determined by the winning
@@ -646,7 +646,7 @@ public static
Flowable combineLatestDelayError(@NonNull Iterable<@NonN
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- *
+ *
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
@@ -692,7 +692,7 @@ public static
Flowable combineLatest(
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- *
+ *
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
@@ -743,7 +743,7 @@ public static
Flowable combineLatest(
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- *
+ *
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
@@ -799,7 +799,7 @@ public static
Flowable combineLatest(
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- *
+ *
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
@@ -860,7 +860,7 @@ public static
Flowable combineLatest(
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- *
+ *
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
@@ -925,7 +925,7 @@ public static
Flowable combineLatest(
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- *
+ *
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
@@ -996,7 +996,7 @@ public static
Flowable combineLatest(
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- *
+ *
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
@@ -1071,7 +1071,7 @@ public static
Flowable combineLatest(
* resulting sequence terminates immediately (normally or with all the errors accumulated until that point).
* If that input source is also synchronous, other sources after it will not be subscribed to.
*
- *
+ *
*
* - Backpressure:
* - The returned {@code Publisher} honors backpressure from downstream. The source {@code Publisher}s
@@ -1147,7 +1147,7 @@ public static
Flowable combineLatest(
* Concatenates elements of each {@link Publisher} provided via an {@link Iterable} sequence into a single sequence
* of elements without interleaving them.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream. The {@code Publisher}
@@ -1177,7 +1177,7 @@ public static
Flowable concat(@NonNull Iterable<@NonNull ? extends Publis
* Returns a {@code Flowable} that emits the items emitted by each of the {@link Publisher}s emitted by the source
* {@code Publisher}, one after the other, without interleaving them.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream. Both the outer and inner {@code Publisher}
@@ -1207,7 +1207,7 @@ public static
Flowable concat(@NonNull Publisher<@NonNull ? extends Publi
* Returns a {@code Flowable} that emits the items emitted by each of the {@link Publisher}s emitted by the source
* {@code Publisher}, one after the other, without interleaving them.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream. Both the outer and inner {@code Publisher}
@@ -1241,7 +1241,7 @@ public static
Flowable concat(@NonNull Publisher<@NonNull ? extends Publi
* Returns a {@code Flowable} that emits the items emitted by two {@link Publisher}s, one after the other, without
* interleaving them.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream. The {@code Publisher}
@@ -1275,7 +1275,7 @@ public static
Flowable concat(@NonNull Publisher<@NonNull ? extends T> so
* Returns a {@code Flowable} that emits the items emitted by three {@link Publisher}s, one after the other, without
* interleaving them.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream. The {@code Publisher}
@@ -1314,7 +1314,7 @@ public static
Flowable concat(
* Returns a {@code Flowable} that emits the items emitted by four {@link Publisher}s, one after the other, without
* interleaving them.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream. The {@code Publisher}
@@ -1357,7 +1357,7 @@ public static
Flowable concat(
*
* Note: named this way because of overload conflict with {@code concat(Publisher>}).
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream. The {@code Publisher}
@@ -1392,7 +1392,7 @@ public static
Flowable concatArray(@NonNull Publisher<@NonNull ? extends
* Concatenates a variable number of {@link Publisher} sources and delays errors from any of them
* till all terminate.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream. The {@code Publisher}
@@ -1997,7 +1997,7 @@ public static
Flowable create(@NonNull FlowableOnSubscribe source, @No
* that subscribes. That is, for each subscriber, the actual {@code Publisher} that subscriber observes is
* determined by the factory function.
*
- *
+ *
*
* The defer {@code Subscriber} allows you to defer or delay emitting items from a {@code Publisher} until such time as a
* {@code Subscriber} subscribes to the {@code Publisher}. This allows a {@code Subscriber} to easily obtain updates or a
@@ -2032,7 +2032,7 @@ public static Flowable defer(@NonNull Supplier extends Publisher<@NonNu
* Returns a {@code Flowable} that emits no items to the {@link Subscriber} and immediately invokes its
* {@link Subscriber#onComplete onComplete} method.
*
- *
+ *
*
* - Backpressure:
* - This source doesn't produce any elements and effectively ignores downstream backpressure.
@@ -2058,7 +2058,7 @@ public static Flowable empty() {
* Returns a {@code Flowable} that invokes a {@link Subscriber}'s {@link Subscriber#onError onError} method when the
* {@code Subscriber} subscribes to it.
*
- *
+ *
*
* - Backpressure:
* - This source doesn't produce any elements and effectively ignores downstream backpressure.
@@ -2087,7 +2087,7 @@ public static Flowable error(@NonNull Supplier extends Throwable> suppl
* Returns a {@code Flowable} that invokes a {@link Subscriber}'s {@link Subscriber#onError onError} method when the
* {@code Subscriber} subscribes to it.
*
- *
+ *
*
* - Backpressure:
* - This source doesn't produce any elements and effectively ignores downstream backpressure.
@@ -2148,7 +2148,7 @@ public static Flowable fromAction(@NonNull Action action) {
/**
* Converts an array into a {@link Publisher} that emits the items in the array.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and iterates the given {@code array}
@@ -2185,7 +2185,7 @@ public static
Flowable fromAction(@NonNull Action action) {
* Returns a {@code Flowable} that, when a {@link Subscriber} subscribes to it, invokes a function you specify and then
* emits the value returned from that function.
*
- *
+ *
*
* This allows you to defer the execution of the function you specify until a {@code Subscriber} subscribes to the
* {@link Publisher}. That is to say, it makes the function "lazy."
@@ -2250,7 +2250,7 @@ public static Flowable fromCompletable(@NonNull CompletableSource complet
/**
* Converts a {@link Future} into a {@link Publisher}.
*
- *
+ *
*
* 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
@@ -2292,7 +2292,7 @@ public static Flowable fromCompletable(@NonNull CompletableSource complet
/**
* Converts a {@link Future} into a {@link Publisher}, with a timeout on the {@code Future}.
*
- *
+ *
*
* 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
@@ -2339,7 +2339,7 @@ public static Flowable fromCompletable(@NonNull CompletableSource complet
/**
* Converts an {@link Iterable} sequence into a {@link Publisher} that emits the items in the sequence.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and iterates the given {@code iterable}
@@ -2559,7 +2559,7 @@ public static
Flowable fromSingle(@NonNull SingleSource source) {
* Returns a {@code Flowable} that, when a {@link Subscriber} subscribes to it, invokes a supplier function you specify and then
* emits the value returned from that function.
*
- *
+ *
*
* This allows you to defer the execution of the function you specify until a {@code Subscriber} subscribes to the
* {@link Publisher}. That is to say, it makes the function "lazy."
@@ -2775,7 +2775,7 @@ public static Flowable generate(@NonNull Supplier initialState, @No
* Returns a {@code Flowable} that emits a {@code 0L} after the {@code initialDelay} and ever-increasing numbers
* after each {@code period} of time thereafter.
*
- *
+ *
*
* - Backpressure:
* - The operator generates values based on time and ignores downstream backpressure which
@@ -2808,7 +2808,7 @@ public static Flowable
interval(long initialDelay, long period, @NonNull T
* Returns a {@code Flowable} that emits a {@code 0L} after the {@code initialDelay} and ever-increasing numbers
* after each {@code period} of time thereafter, on a specified {@link Scheduler}.
*
- *
+ *
*
* - Backpressure:
* - The operator generates values based on time and ignores downstream backpressure which
@@ -2844,7 +2844,7 @@ public static Flowable
interval(long initialDelay, long period, @NonNull T
/**
* Returns a {@code Flowable} that emits a sequential number every specified interval of time.
*
- *
+ *
*
* - Backpressure:
* - The operator signals a {@link MissingBackpressureException} if the downstream
@@ -2873,7 +2873,7 @@ public static Flowable
interval(long period, @NonNull TimeUnit unit) {
* Returns a {@code Flowable} that emits a sequential number every specified interval of time, on a
* specified {@link Scheduler}.
*
- *
+ *
*
* - Backpressure:
* - The operator generates values based on time and ignores downstream backpressure which
@@ -2978,7 +2978,7 @@ public static Flowable
intervalRange(long start, long count, long initialD
/**
* Returns a {@code Flowable} that signals the given (constant reference) item and then completes.
*
- *
+ *
*
* Note that the item is taken and re-emitted as is and not computed by any means by {@code just}. Use {@link #fromCallable(Callable)}
* to generate a single item on demand (when {@link Subscriber}s subscribe to it).
@@ -3018,7 +3018,7 @@ public static Flowable intervalRange(long start, long count, long initialD
/**
* Converts two items into a {@link Publisher} that emits those items.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and signals each value on-demand (i.e., when requested).
@@ -3050,7 +3050,7 @@ public static Flowable intervalRange(long start, long count, long initialD
/**
* Converts three items into a {@link Publisher} that emits those items.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and signals each value on-demand (i.e., when requested).
@@ -3085,7 +3085,7 @@ public static Flowable intervalRange(long start, long count, long initialD
/**
* Converts four items into a {@link Publisher} that emits those items.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and signals each value on-demand (i.e., when requested).
@@ -3124,7 +3124,7 @@ public static Flowable intervalRange(long start, long count, long initialD
/**
* Converts five items into a {@link Publisher} that emits those items.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and signals each value on-demand (i.e., when requested).
@@ -3166,7 +3166,7 @@ public static Flowable intervalRange(long start, long count, long initialD
/**
* Converts six items into a {@link Publisher} that emits those items.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and signals each value on-demand (i.e., when requested).
@@ -3211,7 +3211,7 @@ public static Flowable intervalRange(long start, long count, long initialD
/**
* Converts seven items into a {@link Publisher} that emits those items.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and signals each value on-demand (i.e., when requested).
@@ -3260,7 +3260,7 @@ public static Flowable intervalRange(long start, long count, long initialD
/**
* Converts eight items into a {@link Publisher} that emits those items.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and signals each value on-demand (i.e., when requested).
@@ -3312,7 +3312,7 @@ public static Flowable intervalRange(long start, long count, long initialD
/**
* Converts nine items into a {@link Publisher} that emits those items.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and signals each value on-demand (i.e., when requested).
@@ -3367,7 +3367,7 @@ public static Flowable intervalRange(long start, long count, long initialD
/**
* Converts ten items into a {@link Publisher} that emits those items.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and signals each value on-demand (i.e., when requested).
@@ -3427,7 +3427,7 @@ public static Flowable intervalRange(long start, long count, long initialD
* Flattens an {@link Iterable} of {@link Publisher}s into one {@code Publisher}, without any transformation, while limiting the
* number of concurrent subscriptions to these {@code Publisher}s.
*
- *
+ *
*
* You can combine the items emitted by multiple {@code Publisher}s so that they appear as a single {@code Publisher}, by
* using the {@code merge} method.
@@ -3479,7 +3479,7 @@ public static Flowable merge(@NonNull Iterable<@NonNull ? extends Publish
* Flattens an array of {@link Publisher}s into one {@code Publisher}, without any transformation, while limiting the
* number of concurrent subscriptions to these {@code Publisher}s.
*
- *
+ *
*
* You can combine the items emitted by multiple {@code Publisher}s so that they appear as a single {@code Publisher}, by
* using the {@code merge} method.
@@ -3531,7 +3531,7 @@ public static Flowable mergeArray(int maxConcurrency, int bufferSize, @No
/**
* Flattens an {@link Iterable} of {@link Publisher}s into one {@code Publisher}, without any transformation.
*
- *
+ *
*
* You can combine the items emitted by multiple {@code Publisher}s so that they appear as a single {@code Publisher}, by
* using the {@code merge} method.
@@ -3577,7 +3577,7 @@ public static Flowable merge(@NonNull Iterable<@NonNull ? extends Publish
* Flattens an {@link Iterable} of {@link Publisher}s into one {@code Publisher}, without any transformation, while limiting the
* number of concurrent subscriptions to these {@code Publisher}s.
*
- *
+ *
*
* You can combine the items emitted by multiple {@code Publisher}s so that they appear as a single {@code Publisher}, by
* using the {@code merge} method.
@@ -3627,7 +3627,7 @@ public static Flowable merge(@NonNull Iterable<@NonNull ? extends Publish
* Flattens a {@link Publisher} that emits {@code Publisher}s into a single {@code Publisher} that emits the items emitted by
* thos {@code Publisher}s , without any transformation.
*
- *
+ *
*
* You can combine the items emitted by multiple {@code Publisher}s so that they appear as a single {@code Publisher}, by
* using the {@code merge} method.
@@ -3674,7 +3674,7 @@ public static Flowable merge(@NonNull Publisher<@NonNull ? extends Publis
* those {@code Publisher}s, without any transformation, while limiting the maximum number of concurrent
* subscriptions to these {@code Publisher}s.
*
- *
+ *
*
* You can combine the items emitted by multiple {@code Publisher}s so that they appear as a single {@code Publisher}, by
* using the {@code merge} method.
@@ -3724,7 +3724,7 @@ public static Flowable merge(@NonNull Publisher<@NonNull ? extends Publis
/**
* Flattens an array of {@link Publisher}s into one {@code Publisher}, without any transformation.
*
- *
+ *
*
* You can combine items emitted by multiple {@code Publisher}s so that they appear as a single {@code Publisher}, by
* using the {@code merge} method.
@@ -3770,7 +3770,7 @@ public static Flowable mergeArray(@NonNull Publisher<@NonNull ? extends T
/**
* Flattens two {@link Publisher}s into a single {@code Publisher}, without any transformation.
*
- *
+ *
*
* You can combine items emitted by multiple {@code Publisher}s so that they appear as a single {@code Publisher}, by
* using the {@code merge} method.
@@ -3819,7 +3819,7 @@ public static Flowable merge(@NonNull Publisher<@NonNull ? extends T> sou
/**
* Flattens three {@link Publisher}s into a single {@code Publisher}, without any transformation.
*
- *
+ *
*
* You can combine items emitted by multiple {@code Publisher}s so that they appear as a single {@code Publisher}, by
* using the {@code merge} method.
@@ -3871,7 +3871,7 @@ public static Flowable merge(@NonNull Publisher<@NonNull ? extends T> sou
/**
* Flattens four {@link Publisher}s into a single {@code Publisher}, without any transformation.
*
- *
+ *
*
* You can combine items emitted by multiple {@code Publisher}s so that they appear as a single {@code Publisher}, by
* using the {@code merge} method.
@@ -3934,7 +3934,7 @@ public static Flowable merge(
* error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from propagating that
* error notification until all of the merged {@code Publisher}s have finished emitting items.
*
- *
+ *
*
* Even if multiple merged {@code Publisher}s send {@code onError} notifications, {@code mergeDelayError} will only
* invoke the {@code onError} method of its {@code Subscriber}s once.
@@ -3971,7 +3971,7 @@ public static Flowable mergeDelayError(@NonNull Iterable<@NonNull ? exten
* error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from propagating that
* error notification until all of the merged {@code Publisher}s have finished emitting items.
*
- *
+ *
*
* Even if multiple merged {@code Publisher}s send {@code onError} notifications, {@code mergeDelayError} will only
* invoke the {@code onError} method of its {@code Subscriber}s once.
@@ -4013,7 +4013,7 @@ public static Flowable mergeDelayError(@NonNull Iterable<@NonNull ? exten
* error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from propagating that
* error notification until all of the merged {@code Publisher}s have finished emitting items.
*
- *
+ *
*
* Even if multiple merged {@code Publisher}s send {@code onError} notifications, {@code mergeDelayError} will only
* invoke the {@code onError} method of its {@code Subscriber}s once.
@@ -4056,7 +4056,7 @@ public static Flowable mergeArrayDelayError(int maxConcurrency, int buffe
* error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from propagating that
* error notification until all of the merged {@code Publisher}s have finished emitting items.
*
- *
+ *
*
* Even if multiple merged {@code Publisher}s send {@code onError} notifications, {@code mergeDelayError} will only
* invoke the {@code onError} method of its {@code Subscriber}s once.
@@ -4096,7 +4096,7 @@ public static Flowable mergeDelayError(@NonNull Iterable<@NonNull ? exten
* error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from propagating that
* error notification until all of the merged {@code Publisher}s have finished emitting items.
*
- *
+ *
*
* Even if multiple merged {@code Publisher}s send {@code onError} notifications, {@code mergeDelayError} will only
* invoke the {@code onError} method of its {@code Subscriber}s once.
@@ -4134,7 +4134,7 @@ public static Flowable mergeDelayError(@NonNull Publisher<@NonNull ? exte
* error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from propagating that
* error notification until all of the merged {@code Publisher}s have finished emitting items.
*
- *
+ *
*
* Even if multiple merged {@code Publisher}s send {@code onError} notifications, {@code mergeDelayError} will only
* invoke the {@code onError} method of its {@code Subscriber}s once.
@@ -4175,7 +4175,7 @@ public static Flowable mergeDelayError(@NonNull Publisher<@NonNull ? exte
* error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from propagating that
* error notification until all of the merged {@code Publisher}s have finished emitting items.
*
- *
+ *
*
* Even if multiple merged {@code Publisher}s send {@code onError} notifications, {@code mergeDelayError} will only
* invoke the {@code onError} method of its {@code Subscriber}s once.
@@ -4213,7 +4213,7 @@ public static Flowable mergeArrayDelayError(@NonNull Publisher<@NonNull ?
* notify of an error via {@link Subscriber#onError onError}, {@code mergeDelayError} will refrain from
* propagating that error notification until all of the merged {@code Publisher}s have finished emitting items.
*
- *
+ *
*
* Even if both merged {@code Publisher}s send {@code onError} notifications, {@code mergeDelayError} will only
* invoke the {@code onError} method of its {@code Subscriber}s once.
@@ -4255,7 +4255,7 @@ public static Flowable mergeDelayError(@NonNull Publisher<@NonNull ? exte
* from propagating that error notification until all of the merged {@code Publisher}s have finished emitting
* items.
*
- *
+ *
*
* Even if multiple merged {@code Publisher}s send {@code onError} notifications, {@code mergeDelayError} will only
* invoke the {@code onError} method of its {@code Subscriber}s once.
@@ -4300,7 +4300,7 @@ public static Flowable mergeDelayError(@NonNull Publisher<@NonNull ? exte
* will refrain from propagating that error notification until all of the merged {@code Publisher}s have finished
* emitting items.
*
- *
+ *
*
* Even if multiple merged {@code Publisher}s send {@code onError} notifications, {@code mergeDelayError} will only
* invoke the {@code onError} method of its {@code Subscriber}s once.
@@ -4343,7 +4343,7 @@ public static Flowable mergeDelayError(
/**
* Returns a {@code Flowable} that never sends any items or notifications to a {@link Subscriber}.
*
- *
+ *
*
* This {@link Publisher} is useful primarily for testing purposes.
*
@@ -4370,7 +4370,7 @@ public static Flowable never() {
/**
* Returns a {@code Flowable} that emits a sequence of {@link Integer}s within a specified range.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and signals values on-demand (i.e., when requested).
@@ -4413,7 +4413,7 @@ public static Flowable range(int start, int count) {
/**
* Returns a {@code Flowable} that emits a sequence of {@link Long}s within a specified range.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream and signals values on-demand (i.e., when requested).
@@ -4460,7 +4460,7 @@ public static Flowable rangeLong(long start, long count) {
* Returns a {@link Single} that emits a {@link Boolean} value that indicates whether two {@link Publisher} sequences are the
* same by comparing the items emitted by each {@code Publisher} pairwise.
*
- *
+ *
*
* - Backpressure:
* - This operator honors downstream backpressure and expects both of its sources
@@ -4492,7 +4492,7 @@ public static
Single sequenceEqual(@NonNull Publisher<@NonNull ? ex
* same by comparing the items emitted by each {@code Publisher} pairwise based on the results of a specified
* equality function.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream. The source {@code Publisher}s are expected to honor
@@ -4527,7 +4527,7 @@ public static
Single sequenceEqual(@NonNull Publisher<@NonNull ? ex
* same by comparing the items emitted by each {@code Publisher} pairwise based on the results of a specified
* equality function.
*
- *
+ *
*
* - Backpressure:
* - The operator honors backpressure from downstream. The source {@code Publisher}s are expected to honor
@@ -4568,7 +4568,7 @@ public static
Single sequenceEqual(@NonNull Publisher<@NonNull ? ex
* Returns a {@link Single} that emits a {@link Boolean} value that indicates whether two {@link Publisher} sequences are the
* same by comparing the items emitted by each {@code Publisher} pairwise.
*
- *
+ *
*
* - Backpressure:
* - This operator honors downstream backpressure and expects both of its sources
@@ -4602,7 +4602,7 @@ public static
Single sequenceEqual(@NonNull Publisher<@NonNull ? ex
* Converts a {@link Publisher} that emits {@code Publisher}s into a {@code Publisher} that emits the items emitted by the
* most recently emitted of those {@code Publisher}s.
*
- *
+ *
*
* {@code switchOnNext} subscribes to a {@code Publisher} that emits {@code Publisher}s. Each time it observes one of
* these emitted {@code Publisher}s, the {@code Publisher} returned by {@code switchOnNext} begins emitting the items
@@ -4644,7 +4644,7 @@ public static Flowable switchOnNext(@NonNull Publisher<@NonNull ? extends
* Converts a {@link Publisher} that emits {@code Publisher}s into a {@code Publisher} that emits the items emitted by the
* most recently emitted of those {@code Publisher}s.
*
- *
+ *
*
* {@code switchOnNext} subscribes to a {@code Publisher} that emits {@code Publisher}s. Each time it observes one of
* these emitted {@code Publisher}s, the {@code Publisher} returned by {@code switchOnNext} begins emitting the items
@@ -4683,7 +4683,7 @@ public static Flowable switchOnNext(@NonNull Publisher<@NonNull ? extends
* Converts a {@link Publisher} that emits {@code Publisher}s into a {@code Publisher} that emits the items emitted by the
* most recently emitted of those {@code Publisher}s and delays any exception until all {@code Publisher}s terminate.
*
- *
+ *
*
* {@code switchOnNext} subscribes to a {@code Publisher} that emits {@code Publisher}s. Each time it observes one of
* these emitted {@code Publisher}s, the {@code Publisher} returned by {@code switchOnNext} begins emitting the items
@@ -4723,7 +4723,7 @@ public static Flowable switchOnNextDelayError(@NonNull Publisher<@NonNull
* Converts a {@link Publisher} that emits {@code Publisher}s into a {@code Publisher} that emits the items emitted by the
* most recently emitted of those {@code Publisher}s and delays any exception until all {@code Publisher}s terminate.
*
- *
+ *
*
* {@code switchOnNext} subscribes to a {@code Publisher} that emits {@code Publisher}s. Each time it observes one of
* these emitted {@code Publisher}s, the {@code Publisher} returned by {@code switchOnNext} begins emitting the items
@@ -4765,7 +4765,7 @@ public static Flowable switchOnNextDelayError(@NonNull Publisher<@NonNull
/**
* Returns a {@code Flowable} that emits {@code 0L} after a specified delay, and then completes.
*
- *
+ *
*
* - Backpressure:
* - This operator does not support backpressure as it uses time. If the downstream needs a slower rate
@@ -4794,7 +4794,7 @@ public static Flowable
timer(long delay, @NonNull TimeUnit unit) {
* Returns a {@code Flowable} that emits {@code 0L} after a specified delay, on a specified {@link Scheduler}, and then
* completes.
*
- *
+ *
*
* - Backpressure:
* - This operator does not support backpressure as it uses time. If the downstream needs a slower rate
@@ -4860,7 +4860,7 @@ public static
Flowable