拥有 akka-streams Sink :
val sink: Sink[Foo, Any] = ???
和来自
Bar 的函数至 Foo :val f: Bar => Foo = ???
我想 contramap( map 的反面)
sink与 f得到一个 Sink[Bar, Any] 类型的水槽，但是在库里找不到这么简单的方法。如何实现我所需要的？
最佳答案
与 akka-streams版本2.4.X甚至更简单:
val sink3: Sink[Bar, Future[Done]] = sink.contramap(f)
关于scala - 如何 "contramap"akka-streams 接收器，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/34274050/