将 mapAsync 提取到 AkkaStreams 中的方法

Question

我有一个 Akka Streams 流，有时我需要将 mapAsync 与一段代码结合使用。

    (...)
    .via(flow1)
    .mapAsync(1)(response => 
     * Several linees of code her*
    )
    .via(flow2)

是否有更简洁的方法将其提取到方法中？

    (...)
    .via(flow1)
    .doComputations
    .via(flow2)

Answer 1

添加新流程

val asyncProc = Flow[T].mapAsync(1) { response => 
// Several lines of code here
}

并与via

一起使用

flow1
  .via(asyncProc)
  .via(flow2)

Extract mapAsync to method in AkkaStreams