Skip to content

Commit 3c83ff0

Browse files
ganapathi004akarnokd
authored andcommitted
Corrected return type in doc for F.reduce(seed, reducer), F.reduceWith(seedSupplier, reducer) and O.reduce(seed, reducer) (#5478)
1 parent cf6f5b8 commit 3c83ff0

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/main/java/io/reactivex/Flowable.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10787,7 +10787,7 @@ public final Maybe<T> reduce(BiFunction<T, T, T> reducer) {
1078710787
* @param reducer
1078810788
* an accumulator function to be invoked on each item emitted by the source Publisher, the
1078910789
* result of which will be used in the next accumulator call
10790-
* @return a Flowable that emits a single item that is the result of accumulating the output from the
10790+
* @return a Single that emits a single item that is the result of accumulating the output from the
1079110791
* items emitted by the source Publisher
1079210792
* @see <a href="http://reactivex.io/documentation/operators/reduce.html">ReactiveX operators documentation: Reduce</a>
1079310793
* @see <a href="http://en.wikipedia.org/wiki/Fold_(higher-order_function)">Wikipedia: Fold (higher-order function)</a>
@@ -10803,7 +10803,7 @@ public final <R> Single<R> reduce(R seed, BiFunction<R, ? super T, R> reducer) {
1080310803
}
1080410804

1080510805
/**
10806-
* Returns a Flowable that applies a specified accumulator function to the first item emitted by a source
10806+
* Returns a Single that applies a specified accumulator function to the first item emitted by a source
1080710807
* Publisher and a seed value derived from calling a specified seedSupplier, then feeds the result
1080810808
* of that function along with the second item emitted by a Publisher into the same function, and so on until
1080910809
* all items have been emitted by the source Publisher, emitting the final result from the final call to your
@@ -10828,7 +10828,7 @@ public final <R> Single<R> reduce(R seed, BiFunction<R, ? super T, R> reducer) {
1082810828
* @param reducer
1082910829
* an accumulator function to be invoked on each item emitted by the source Publisher, the
1083010830
* result of which will be used in the next accumulator call
10831-
* @return a Flowable that emits a single item that is the result of accumulating the output from the
10831+
* @return a Single that emits a single item that is the result of accumulating the output from the
1083210832
* items emitted by the source Publisher
1083310833
* @see <a href="http://reactivex.io/documentation/operators/reduce.html">ReactiveX operators documentation: Reduce</a>
1083410834
* @see <a href="http://en.wikipedia.org/wiki/Fold_(higher-order_function)">Wikipedia: Fold (higher-order function)</a>

src/main/java/io/reactivex/Observable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9027,7 +9027,7 @@ public final Maybe<T> reduce(BiFunction<T, T, T> reducer) {
90279027
* @param reducer
90289028
* an accumulator function to be invoked on each item emitted by the source ObservableSource, the
90299029
* result of which will be used in the next accumulator call
9030-
* @return an Observable that emits a single item that is the result of accumulating the output from the
9030+
* @return a Single that emits a single item that is the result of accumulating the output from the
90319031
* items emitted by the source ObservableSource
90329032
* @see <a href="http://reactivex.io/documentation/operators/reduce.html">ReactiveX operators documentation: Reduce</a>
90339033
* @see <a href="http://en.wikipedia.org/wiki/Fold_(higher-order_function)">Wikipedia: Fold (higher-order function)</a>

0 commit comments

Comments
 (0)