如何在akka-streams中使用"contramap"来处理Sink

Question

拥有一个 akka-streams 的 Sink:

val sink: Sink[Foo, Any] = ???

以及从Bar到Foo的函数：

val f: Bar => Foo = ???

我想使用f来反向映射(contramap) sink，得到一个类型为Sink [Bar，Any]的sink，但是在库中找不到这样简单的方法。如何实现我所需的功能？

- Tvaroh

Answer 1

使用akka-streams版本2.4.X，操作更加简单:

val sink3: Sink[Bar, Future[Done]] = sink.contramap(f)

- Filippo Vitale

Answer 2

原来这很简单。

创建一个接受Bar的Flow：

val flow: Flow[Bar, Bar, Unit] = Flow[Bar]

并将其与f映射，通过管道将结果传送回原始sink：

val sink2: Sink[Bar, Unit] = flow.map(f).to(sink)

- Tvaroh