在 subscribe 中订阅并在 Angular 中返回一个 observable

Question

在这方面真的需要帮助。我一直在尝试不同的东西，但它不起作用。

function1() {
  return this.apiService.get().pipe(map(data => {
    return this.function2();
  }));
  }

function2() {
   const urls = [];

   for (let i = 1; i <= 5; i++) {
      urls.push(
        this.apiService
          .get('/users/?page=' + i)
          .pipe(map(data => data))
      );
    }

   forkJoin(...urls).subscribe(data => {
     data.forEach(element => {
        results = results.concat(element.results);
      });
     return results;
     })
    }


this.someService.function1().subscribe(data => {
console.log(data);
})

所以基本上，我想打印出我在 function1() 中订阅的数据。但是function1()的结果依赖于另一个subscribe()的function2()。

我知道为什么，但就是不知道如何解决。当我运行脚本时，我总是不确定，原因是 function1() 无法等待 function2() 返回结果。

我被困在这里了。谢谢，

回答：我发现我不应该将 function2 中的结果作为数组返回。

function2() {
   const urls = [];

   for (let i = 1; i <= 5; i++) {
      urls.push(
        this.apiService
          .get('/users/?page=' + i)
          .pipe(map(data => data))
      );
    }

   return forkJoin(urls);

然后根据 function2 的输出，我将在 function1 中完成剩下的工作，即 concat()....

Answer 1

你会想要switchMap - Documentation

从function1 获得结果后，您想“切换”到等待function2

function1() {
    return this.apiService.get().pipe(switchMap(function1Data => {
        // Send function2 whatever data it needs
        // Example:
        return this.function2(function1Data.function2Argument).pipe(map(function2Data => {
            // Combine function1Data and function2Data as needed
            // Example:
            const result = {
                function1Property: function1Data.property,
                function2Property: function2Data.property
            };
            return result;
        }));
    });
}