This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 2e33ec5883 Align groupBy with scala version (#2816)
2e33ec5883 is described below
commit 2e33ec5883c0cbc79c7f4539b1e77a89c7688f27
Author: Philippus Baalman <[email protected]>
AuthorDate: Sat Mar 28 11:09:20 2026 +0100
Align groupBy with scala version (#2816)
---
docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java
b/docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java
index 65c985d849..1a46e7fe1d 100644
--- a/docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java
+++ b/docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java
@@ -693,12 +693,12 @@ class SourceOrFlow {
void groupByExample() {
// #groupBy
Source.range(1, 10)
- .groupBy(2, i -> i % 2 == 0) // create two sub-streams with odd and
even numbers
+ .groupBy(2, i -> i % 2) // create two sub-streams with odd and even
numbers
.reduce(Integer::sum) // for each sub-stream, sum its elements
.mergeSubstreams() // merge back into a stream
.runForeach(System.out::println, system);
- // 25
- // 30
+ // 30 (even: 2+4+6+8+10)
+ // 25 (odd: 1+3+5+7+9)
// #groupBy
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
