This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch 1.7.x
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/1.7.x by this push:
new 6d5da10b50 Fix image paths in substream docs (#3470) (#3476)
6d5da10b50 is described below
commit 6d5da10b50ac3f01f8b40570e02aeeef419dd2e5
Author: PJ Fanning <[email protected]>
AuthorDate: Thu Aug 27 17:27:17 2026 +0100
Fix image paths in substream docs (#3470) (#3476)
Co-authored-by: Michael Stringer <[email protected]>
---
docs/src/main/paradox/stream/stream-substream.md | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/docs/src/main/paradox/stream/stream-substream.md
b/docs/src/main/paradox/stream/stream-substream.md
index 435b4254b9..26d10dbbf7 100644
--- a/docs/src/main/paradox/stream/stream-substream.md
+++ b/docs/src/main/paradox/stream/stream-substream.md
@@ -35,7 +35,7 @@ Scala
Java
: @@snip
[SubstreamDocTest.java](/docs/src/test/java/jdocs/stream/SubstreamDocTest.java)
{ #groupBy1 }
-
+
This operation splits the incoming stream into separate output
streams, one for each element key. The key is computed for each element
@@ -54,7 +54,7 @@ Scala
Java
: @@snip
[SubstreamDocTest.java](/docs/src/test/java/jdocs/stream/SubstreamDocTest.java)
{ #groupBy2 }
-
+
Also substreams, more precisely, @apidoc[stream.*.SubFlow] @java[and
@javadoc[SubSource](pekko.stream.javadsl.SubSource)] have methods that allow
you to
merge or concat substreams into the main stream again.
@@ -67,7 +67,7 @@ Scala
Java
: @@snip
[SubstreamDocTest.java](/docs/src/test/java/jdocs/stream/SubstreamDocTest.java)
{ #groupBy3 }
-
+
You can limit the number of active substreams running and being merged at a
time,
with either the @apidoc[mergeSubstreamsWithParallelism](stream.*.SubFlow)
{scala="#mergeSubstreamsWithParallelism(parallelism:Int):F[Out]"
java="#mergeSubstreamsWithParallelism(int)"} or
@apidoc[concatSubstreams](stream.*.SubFlow) {scala="#concatSubstreams:F[Out]"
java="#concatSubstreams()"} method.
@@ -85,7 +85,7 @@ Element one and two leads to two created substreams, but
since the number of sub
when element 3 comes in it cannot lead to creation of a new substream until
one of the previous two are completed
and this leads to the stream being deadlocked.
-
+
### splitWhen and splitAfter
@@ -120,7 +120,7 @@ This prints out the following output.
26
```
-
+
## Flattening operators
@@ -138,7 +138,7 @@ Scala
Java
: @@snip
[SubstreamDocTest.java](/docs/src/test/java/jdocs/stream/SubstreamDocTest.java)
{ #flatMapConcat }
-
+
Like the `concat` operation on @apidoc[stream.*.Flow], it fully consumes one
@apidoc[stream.*.Source] after the other.
So, there is only one substream actively running at a given time.
@@ -146,7 +146,7 @@ So, there is only one substream actively running at a given
time.
Then once the active substream is fully consumed, the next substream can start
running.
Elements from all the substreams are concatenated to the sink.
-
+
### flatMapMerge
@@ -159,4 +159,4 @@ Scala
Java
: @@snip
[SubstreamDocTest.java](/docs/src/test/java/jdocs/stream/SubstreamDocTest.java)
{ #flatMapMerge }
-
+
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]