javascript 如果mergeAll设置为10,如何等待所有观察对象完成?

qyzbxkaa  于 2023-02-11  发布在  Java
关注(0)|答案(1)|浏览(92)

我对API的并发请求有问题。如果一次执行太多的请求(可以是200+),它们就会开始失败并出现错误。
这里有一个学生列表,我需要为他们创建测试任务,1个学生1个API调用。我使用forkJoint对带有API调用的可观察项进行分组,并等待所有请求完成,之后用户会收到一个通知,通知学生已分配测试。
它工作正常,因为浏览器限制请求数量,如果我没记错的话,Chrome是10个。但是HTTP/2这个限制不起作用,我用了这个example,它帮助解决了请求数量的问题,但是我仍然要等待所有(200+)请求完成才能显示通知。我不知道如何用RxJ来实现它。

mwg9r5ms

mwg9r5ms1#

最终解如下所示:

from(observables)
  .pipe(mergeAll(10), toArray())
  .subscribe();

相关问题