压扁嵌套Observables.subscribe

Question

我是新来Observables与rx.js，我想知道我怎么可以拼合以下回调地狱：

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"); 
    }); 
}); 

我知道，如果这是承诺，then()可能已被使用把它弄平。但我不知道相当于then()的Observables。

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]; 
    (...) 
});