如何解决基于父流的子流上的Akka流缓冲区
我正在使用akka-streams,但由于最大化了akka-http上的Http Pool,导致出现异常。 有一个列表元素的源,它被拆分并转换为SubFlows。 子流发出http请求。尽管我在SubFlow上放置了一个缓冲区,但该缓冲区似乎对每个SubFlow都有效。 有没有一种方法可以使基于Source的缓冲区对SubFlow生效?
解决方法
我的错误是我在合并子流时没有考虑使用的并行性
def mergeSubstreams(): Flow[In,Out,Mat]
来自文档
这与
mergeSubstreamsWithParallelism(Integer.MAX_VALUE)
的作用相同。
因此,我的解决方法是使用
def mergeSubstreamsWithParallelism(parallelism: Int): Flow[In,Mat]
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。