Извлечь mapAsyn c в метод в AkkaStreams

Question

У меня есть поток Akka Streams, в какой-то момент мне нужно использовать mapAsyn c с блоком кода.

    (...)
    .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)