Akka在没有水流的情况下合并水槽

Question

我使用的API接受单个AKKA接收器，并用数据填充：

def fillSink(sink:Sink[String, _])

有没有一种方法，在不深入阿卡的深度的情况下，用两个汇而不是一个汇来处理输出？

例如

val mySink1:Sink = ...
val mySink2:Sink = ...
//something
fillSink( bothSinks )

如果我可以访问fillSink方法使用的Flow，我可以使用flow.alsoTo（mySink1）. to（mySink2），但流不会公开。

目前唯一的解决方法是将一个处理字符串的水槽传递给两个StringBuilder，以替换mySink1/mySink2，但这似乎违背了AKKA的观点。如果不花几天时间学习AKKA，我就不知道是否有办法将输出从接收器中分离出来。

谢谢

Answer 1

combineSink操作符，它使用提供的Int组合两个或多个接收器=

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

一个微不足道的例子：

val doubleSink = Sink.foreach[Int](i => println(s"Doubler: ${i*2}"))
val tripleSink = Sink.foreach[Int](i => println(s" Triper: ${i*3}"))

val combinedSink = Sink.combine(doubleSink, tripleSink)(Broadcast[Int](_))

Source(List(1, 2, 3)).runWith(combinedSink)

// Doubler: 2
//  Triper: 3
// Doubler: 4
//  Triper: 6
// Doubler: 6
//  Triper: 9