我有一个Akka Streams流，在某个时候我需要使用mapAsync和一段代码。
(...) .via(flow1) .mapAsync(1)(response => * Several linees of code her* ) .via(flow2)
是否有更干净的方法将其提取到方法中？
(...) .via(flow1) .doComputations .via(flow2)
8nuwlpux1#
添加新流
val asyncProc = Flow[T].mapAsync(1) { response => // Several lines of code here }
并将其与via一起使用
via
flow1 .via(asyncProc) .via(flow2)
1条答案
按热度按时间8nuwlpux1#
添加新流
并将其与
via一起使用