Merge pull request #30522 from raboof/link-mapConcat-with-flatMapConcat-and-flatMapMerge

Link mapConcat, flatMapConcat and flatMapMerge
This commit is contained in:
Patrik Nordwall 2021-08-18 12:36:49 +02:00 committed by GitHub
commit 273192f2a9
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 4 additions and 4 deletions

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)" }
See also: @ref:[flatMapMerge](flatMapMerge.md)
## Description
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.
See also: @ref:[flatMapMerge](flatMapMerge.md), @ref:[mapConcat](mapConcat.md)
## Example
In the following example `flatMapConcat` is used to create a `Source` for each incoming customerId. This could be, for example,

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
different active `Source`s.
See also: @ref:[flatMapConcat](flatMapConcat.md)
See also: @ref:[flatMapConcat](flatMapConcat.md), @ref:[mapConcat](mapConcat.md)
## Example

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
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