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

Question

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

如果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)
}