add example to the doc of combine operator (#30194)
This commit is contained in:
parent
571aa85a36
commit
099e20ec6d
1 changed files with 18 additions and 1 deletions
|
|
@ -6,12 +6,29 @@ Combine several sinks into one using a user specified strategy
|
||||||
|
|
||||||
## Signature
|
## Signature
|
||||||
|
|
||||||
@apidoc[Sink.combine](Sink$) { scala="#combine[T,U](first:akka.stream.scaladsl.Sink[U,_],second:akka.stream.scaladsl.Sink[U,_],rest:akka.stream.scaladsl.Sink[U,_]*)(strategy:Int=>akka.stream.Graph[akka.stream.UniformFanOutShape[T,U],akka.NotUsed]):akka.stream.scaladsl.Sink[T,akka.NotUsed]" java="#combine(akka.stream.javadsl.Sink,akka.stream.javadsl.Sink,java.util.List,akka.japi.function.Function)" }
|
@apidoc[Sink.combine](Sink$) { scala="
|
||||||
|
#combine[T,U](first:akka.stream.scaladsl.Sink[U,_],second:akka.stream.scaladsl.Sink[U,_],rest:akka.stream.scaladsl.Sink[U,_]*)(
|
||||||
|
strategy:Int=>akka.stream.Graph[akka.stream.UniformFanOutShape[T,U],akka.NotUsed]):
|
||||||
|
akka.stream.scaladsl.Sink[T,akka.NotUsed]" java="#combine(
|
||||||
|
akka.stream.javadsl.Sink,akka.stream.javadsl.Sink,java.util.List,akka.japi.function.Function)" }
|
||||||
|
|
||||||
## Description
|
## Description
|
||||||
|
|
||||||
Combine several sinks into one using a user specified strategy
|
Combine several sinks into one using a user specified strategy
|
||||||
|
|
||||||
|
## Example
|
||||||
|
|
||||||
|
This example shows how to combine multiple sinks with a Fan-out Junction.
|
||||||
|
|
||||||
|
Scala
|
||||||
|
:
|
||||||
|
@@snip [StreamPartialGraphDSLDocSpec.scala](/akka-docs/src/test/scala/docs/stream/StreamPartialGraphDSLDocSpec.scala) {
|
||||||
|
#sink-combine }
|
||||||
|
|
||||||
|
Java
|
||||||
|
: @@snip [StreamPartialGraphDSLDocTest.java](/akka-docs/src/test/java/jdocs/stream/StreamPartialGraphDSLDocTest.java)
|
||||||
|
{ #sink-combine }
|
||||||
|
|
||||||
## Reactive Streams semantics
|
## Reactive Streams semantics
|
||||||
|
|
||||||
@@@div { .callout }
|
@@@div { .callout }
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue