raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Link mapConcat, flatMapConcat and flatMapMerge

Browse source 
For better discoverability
This commit is contained in:
Arnout Engelen 2021-08-11 12:11:45 +02:00
parent e39fb57b0c
commit 9e20f76cc0
No known key found for this signature in database
GPG key ID: 061107B0F74A6DAA
3 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-docs/src/main/paradox/stream/operators/Source-or-Flow/flatMapConcat.md
View file

@ -9,13 +9,13 @@ Transform each input element into a `Source` whose elements are then flattened i
@apidoc[Flow.flatMapConcat](Flow) { scala="#flatMapConcat[T,M](f:Out=%3akka.stream.Graph[akka.stream.SourceShape[T],M]):FlowOps.this.Repr[T]" java="#flatMapConcat(akka.japi.function.Function)" } @apidoc[Flow.flatMapConcat](Flow) { scala="#flatMapConcat[T,M](f:Out=%3akka.stream.Graph[akka.stream.SourceShape[T],M]):FlowOps.this.Repr[T]" java="#flatMapConcat(akka.japi.function.Function)" }
See also: @ref:[flatMapMerge](flatMapMerge.md)
## Description ## Description
Transform each input element into a `Source` whose elements are then flattened into the output stream through Transform each input element into a `Source` whose elements are then flattened into the output stream through
concatenation. This means each source is fully consumed before consumption of the next source starts. concatenation. This means each source is fully consumed before consumption of the next source starts.
See also: @ref:[flatMapMerge](flatMapMerge.md), @ref:[mapConcat](mapConcat.md)
## Example ## Example
In the following example `flatMapConcat` is used to create a `Source` for each incoming customerId. This could be, for example, In the following example `flatMapConcat` is used to create a `Source` for each incoming customerId. This could be, for example,

2
akka-docs/src/main/paradox/stream/operators/Source-or-Flow/flatMapMerge.md
View file

@ -16,7 +16,7 @@ request any more elements meaning that it back pressures until one of the existi
Order of the elements for each `Source` is preserved but there is no deterministic order between elements from Order of the elements for each `Source` is preserved but there is no deterministic order between elements from
different active `Source`s. different active `Source`s.
See also: @ref:[flatMapConcat](flatMapConcat.md) See also: @ref:[flatMapConcat](flatMapConcat.md), @ref:[mapConcat](mapConcat.md)
## Example ## Example

2
akka-docs/src/main/paradox/stream/operators/Source-or-Flow/mapConcat.md
View file

@ -17,7 +17,7 @@ This can be used to flatten collections into individual stream elements.
Returning an empty iterable results in zero elements being passed downstream Returning an empty iterable results in zero elements being passed downstream
rather than the stream being cancelled. rather than the stream being cancelled.
See also @ref:[statefulMapConcat](statefulMapConcat.md) See also @ref:[statefulMapConcat](statefulMapConcat.md), @ref:[flatMapConcat](flatMapConcat.md), @ref:[flatMapMerge](flatMapMerge.md)
## Example ## Example