Akka：使用物化值转换接收器的输入

Question

我有一个接收器：Sink[String, Mat]，并希望通过映射每个元素：num: Int => ("num" + num): String 并将其转换为接收器：Sink[Int, Mat]，并保留原始的具体化类型和值。

如果Mat 是Unit，那么很简单：

def transformSink(sink: Sink[String, Unit]): Sink[Int, Unit] =
  Flow[Int].map("num" + _).to(sink)

但是如何为任何Mat 转换接收器呢？

def transformSink[Mat](sink: Sink[String, Mat]): Sink[Int, Mat] = ???

Answer 1

我认为toMat 是您正在寻找的。看看这是否适合你：

def transformSink[Mat](sink: Sink[String, Mat]): Sink[Int, Mat] =
  Flow[Int].map("num" + _).toMat(sink)(Keep.right)
}