javascript - 展平嵌套的 Observables.subscribe

Question

我是使用 rx.js 的 Observables 的新手，我想知道如何平息以下回调 hell :

function getdata1 (argument) {
    return this.http.get(url)
        .map((res: Response) => res.json());
}

function getdata2 (argument) {
    return this.http.get(url)
        .map((res: Response) => res.json());
}

getdata1.subscribe((data1: any) => {
    console.log("got data one. get data 2 now");
    getdata2.subscribe((data2: any) => {
        console.log("got data one and two here");
    });
});

我知道如果这是 Promises，then() 可以用来压扁它。但我不知道 Observables 中的 then() 等价物。

Answer 1

您可以将 flatMap 运算符与 Observable.forkJoin 一起使用:

getdata1().flatMap(data1 => {
  return Observable.forkJoin([
    Observable.of(data1);
    getdata2()
  ]);
}).subscribe(result => {
  var data1 = result[0];
  var data2 = result[1];
  (...)
});