【发布时间】：2020-09-11 17:59:35
【问题描述】：
我正在使用 akka-streams，但由于 akka-http 上的 Http Pool 最大化，我遇到了异常。 有一个列表元素的来源，它被拆分并因此转换为子流。 子流发出 http 请求。虽然我在子流上放了一个缓冲区，但似乎缓冲区对每个子流都有效。 有没有办法让基于 Source 的缓冲区对 SubFlows 生效？
【问题讨论】：
标签： akka-stream akka-http reactive alpakka
【发布时间】：2020-09-11 17:59:35
【问题描述】：
我的错误是我在没有考虑并行性的情况下合并子流
def mergeSubstreams(): Flow[In, Out, Mat]
来自文档
这与
mergeSubstreamsWithParallelism(Integer.MAX_VALUE)的效果相同。
因此我的解决方法是使用
def mergeSubstreamsWithParallelism(parallelism: Int): Flow[In, Out, Mat]
【讨论】：