RxJ中依赖于链的可观察变量

Question

链接一系列HttpClient调用的“最佳实践”是什么（假设当前调用取决于先前调用的结果）？以下解决方案是有效的，但显然不建议这样做。每个get返回一个Observable。在解决方案（RxJs中的较新方法）中首选使用“管道”运算符。

ngOnInit() {
  this.firstService.get().subscribe((first) => {
    this.secondService.get().subscribe(second => {
      this.thirdService.get().subscribe(third => {
        ... possibly more nested calls ...
      })
    })
  })
}

Answer 1

您的代码远远超出了最佳实践。切勿在另一个内部进行订阅。

如果您的任务是彼此独立的三个独立任务/可观察对象，则考虑使用forkJoin（所有可观察对象同时开始，最后一个可观察对象完成时返回结果）

let observable1(param1);
let observable2(param2);
let observable3(param3);

let joinedObservables = forkJoin(observable1, observable2, observable3).subscribe(x => {
  let result1 = x[0];
  let result2 = x[1];
  let result3 = x[2];

  ...
});

如果他们的结果依赖于对方，你可以使用switchMap，flatMap，mergeMap，exhaustMap（检查差异）

let resultObservable =  return this.observable1().pipe(mergeMap((param1) => {
  return this.observable2().pipe(map((param1) => {

    ....        

    return <result>;
  }));
}));

resultObservable.subscribe(x => {
   ...
});