シンク: があり、各要素をマッピングして、元の実体化された型と値を保持することにより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] = ???