基于父流的子流上的 Akka Streams 缓冲区
Akka Streams buffer on SubFlows based on parent Flow
我正在使用 akka-streams，但由于 akka-http 上的 Http 池已用尽而遇到异常。
有一个列表元素源，它被拆分并因此转换为子流。
SubFlows 发出 http 请求。虽然我在 SubFlow 上放置了一个缓冲区，但似乎缓冲区对每个 SubFlow 都有效。
有没有一种方法可以使基于源的缓冲区对子流生效？
我的错误是我在合并子流时没有考虑使用
的并行性
def mergeSubstreams(): Flow[In, Out, Mat]
来自文档
This is identical in effect to mergeSubstreamsWithParallelism(Integer.MAX_VALUE).
因此我的解决方法是使用
def mergeSubstreamsWithParallelism(parallelism: Int): Flow[In, Out, Mat]
我正在使用 akka-streams，但由于 akka-http 上的 Http 池已用尽而遇到异常。 有一个列表元素源，它被拆分并因此转换为子流。 SubFlows 发出 http 请求。虽然我在 SubFlow 上放置了一个缓冲区，但似乎缓冲区对每个 SubFlow 都有效。 有没有一种方法可以使基于源的缓冲区对子流生效？
我的错误是我在合并子流时没有考虑使用
的并行性def mergeSubstreams(): Flow[In, Out, Mat]
来自文档
This is identical in effect to
mergeSubstreamsWithParallelism(Integer.MAX_VALUE).
因此我的解决方法是使用
def mergeSubstreamsWithParallelism(parallelism: Int): Flow[In, Out, Mat]