У меня есть приемник: 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] = ???