pekko/akka-docs/src/main/paradox/stream/operators/Sink/combine.md

Sink.combine

Combine several sinks into one using a user specified strategy

@refSink operators

Signature

@apidocSink.combine { scala="#combineT,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

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 {#sink-combine }

Java

@@snip StreamPartialGraphDSLDocTest.java { #sink-combine }

Reactive Streams semantics

@@@div { .callout }

cancels depends on the strategy

backpressures depends on the strategy

@@@