combine

Combine several sinks into one using a user specified strategy

Sink stages

Signature

def combine[T, U](first: Sink[U, _], second: Sink[U, _], rest: Sink[U, _]*)(strategy: Int ⇒ Graph[UniformFanOutShape[T, U], NotUsed]): Sink[T, NotUsed]

Description

Combine several sinks into one using a user specified strategy

cancels depends on the strategy

backpressures depends on the strategy

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.