Angular 8 在异步调用链后返回 observable

Question

我有一个简单的函数，像这样依次调用 3 个异步函数：

getData() {
    this.getUsers('2')
        .pipe(
        flatMap((data: any) => {  
            return this.getPosts(data.id);
        }),
        flatMap((data: any) => {            
            return this.getPosts(data[0].userId);
        })
        ).subscribe(results => {    
        return new Observable((observer) => {
        observer.next(results);
        observer.complete();
        });
    });
}

我希望以某种方式能够调用类似： this.getdata.subscribe() 并且在所有 3 个平面地图都完成后调用。我假设我必须让 getData() 函数返回一个我尝试在底部执行的 observable，但它不起作用，我无法在 getData() 函数上调用 .subscribe。

Answer 1

试试这样：

Working Demo

getData() {
    return this.getUsers('2')
      .pipe(
        flatMap((data: any) => {  
          return this.getPosts(data.id);
        }),
        flatMap((data: any) => {            
          return this.getPosts(data[0].userId);
        })
      )
  }