平坦化ネストされたObservables.subscribe

Question

私はrx.jsとObservablesに新しいですし、私は次のコールバック地獄を平らにする方法を知りたいと思った：

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()が使用されている可能性が知っていますそれを平らにする。しかしObservablesにはthen()と同等のものはありません。

Answer 1

あなたはObservable.forkJoinでflatMap演算子を使用することができます。

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