From 5c2b102d647dfec4cc4a369d288d0839bb854bda Mon Sep 17 00:00:00 2001 From: fsbarata Date: Thu, 12 Nov 2020 09:34:52 +0000 Subject: [PATCH 1/2] 3.x: Flowable scan/scanWith backpressure documentation update Documented Flowable initial value scan variants upstream consumption pattern as it is different from the variant with no initial value. --- src/main/java/io/reactivex/rxjava3/core/Flowable.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/main/java/io/reactivex/rxjava3/core/Flowable.java b/src/main/java/io/reactivex/rxjava3/core/Flowable.java index a8c873bbc4..3ce4ac0e50 100644 --- a/src/main/java/io/reactivex/rxjava3/core/Flowable.java +++ b/src/main/java/io/reactivex/rxjava3/core/Flowable.java @@ -14736,6 +14736,8 @@ public final Flowable scan(@NonNull BiFunction accumulator) { *
Backpressure:
*
The operator honors downstream backpressure and expects the current {@code Flowable} to honor backpressure as well. * Violating this expectation, a {@link MissingBackpressureException} may get signaled somewhere downstream.
+ *
The downstream request pattern is not preserved across this operator. + * The upstream is requested {@link #bufferSize()} - 1 upfront and 75% of {@link #bufferSize()} thereafter.
*
Scheduler:
*
{@code scan} does not operate by default on a particular {@link Scheduler}.
* @@ -14775,6 +14777,8 @@ public final Flowable scan(@NonNull BiFunction accumulator) { *
Backpressure:
*
The operator honors downstream backpressure and expects the current {@code Flowable} to honor backpressure as well. * Violating this expectation, a {@link MissingBackpressureException} may get signaled somewhere downstream.
+ *
The downstream request pattern is not preserved across this operator. + * The upstream is requested {@link #bufferSize()} - 1 upfront and 75% of {@link #bufferSize()} thereafter.
*
Scheduler:
*
{@code scanWith} does not operate by default on a particular {@link Scheduler}.
* From e416b6f8aef1a9bd5f61de2de5abae71c9c32f95 Mon Sep 17 00:00:00 2001 From: fsbarata Date: Thu, 12 Nov 2020 09:54:02 +0000 Subject: [PATCH 2/2] 3.x: Flowable scan/scanWith backpressure documentation merge
sections --- .../java/io/reactivex/rxjava3/core/Flowable.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/main/java/io/reactivex/rxjava3/core/Flowable.java b/src/main/java/io/reactivex/rxjava3/core/Flowable.java index 3ce4ac0e50..364e83fd58 100644 --- a/src/main/java/io/reactivex/rxjava3/core/Flowable.java +++ b/src/main/java/io/reactivex/rxjava3/core/Flowable.java @@ -14735,9 +14735,9 @@ public final Flowable scan(@NonNull BiFunction accumulator) { *
*
Backpressure:
*
The operator honors downstream backpressure and expects the current {@code Flowable} to honor backpressure as well. - * Violating this expectation, a {@link MissingBackpressureException} may get signaled somewhere downstream.
- *
The downstream request pattern is not preserved across this operator. - * The upstream is requested {@link #bufferSize()} - 1 upfront and 75% of {@link #bufferSize()} thereafter.
+ * Violating this expectation, a {@link MissingBackpressureException} may get signaled somewhere downstream. + * The downstream request pattern is not preserved across this operator. + * The upstream is requested {@link #bufferSize()} - 1 upfront and 75% of {@link #bufferSize()} thereafter.
*
Scheduler:
*
{@code scan} does not operate by default on a particular {@link Scheduler}.
* @@ -14776,9 +14776,9 @@ public final Flowable scan(@NonNull BiFunction accumulator) { *
*
Backpressure:
*
The operator honors downstream backpressure and expects the current {@code Flowable} to honor backpressure as well. - * Violating this expectation, a {@link MissingBackpressureException} may get signaled somewhere downstream.
- *
The downstream request pattern is not preserved across this operator. - * The upstream is requested {@link #bufferSize()} - 1 upfront and 75% of {@link #bufferSize()} thereafter.
+ * Violating this expectation, a {@link MissingBackpressureException} may get signaled somewhere downstream. + * The downstream request pattern is not preserved across this operator. + * The upstream is requested {@link #bufferSize()} - 1 upfront and 75% of {@link #bufferSize()} thereafter. *
Scheduler:
*
{@code scanWith} does not operate by default on a particular {@link Scheduler}.
*