将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)