如何循环 .subscribe observable

Question

我目前正在尝试创建一个循环的函数，并通过使用 .subscribe 每次都得到一个数组对象，以便稍后我可以将数据推送到另一个数组中。循环有效，但问题是结果不是我想要的，因为 .subscribe 部分正在打印第一个数组，然后其余部分给我空数组，而它假设打印 20x 相同的数组。我目前开始尝试使用 angular 并且根据我对其他语言的了解，我认为首先打印“Test”x20 并在进入订阅和打印之后效果不佳。

功能：

testingFunction()
{
   let i: number = 0;

   while(i < 20){

   console.log("Test");

   this.testService.getAll().subscribe((object: any[]) => {
      console.log(object);
   })

    i++;
  }
}

Answer 1

由于您使用的是 Angular，因此您可以使用 RxJS 运算符来处理这种情况。 forkJoin 运算符将允许您在返回所有可观察对象之前等待 while 循环操作完成。

这是你如何使用操作符：

testingFunction() {
   let i: number = 0;
   const observablesList = []; 

   while(i < 20){
     observablesList.push(this.testService.getAll());
     i++;
   }
   forkJoin(observablesList).subscribe((response) => {
     console.log(response);
   });
}