RxJs：どのように2回の観測のサブスクリプションでの作業が

Question

を行う場合にメソッドを呼び出すために、私は別のAPIエンドポイントからのデータをロードし、各データセットにいくつかの同期作業を行うよ：

// Invoked by user interaction 
loadData() { 
    this.service1.getData().subscribe(
     data => { 
     this.doSynchronousWork(data); 
     this.data1 = data; 
     } 
    ); 

    this.service2.getData().subscribe(
     data => { 
     this.doSynchronousWork(data); 
     this.data2 = data; 
     } 
    ); 
} 

// To be invoked when this.data1 and this.data2 is available 
doSynchronousWorkWhenAllDataIsLoadedAndProcessed() 

は今、私が呼び出す必要があります両方のサブスクリプションが作業を完了したときに別の同期メソッド。どうやってやるの？これを実現するために

Answer 1

、あなたは配列として、すべての観測を追加し、彼らはasynchronuouslyそう

import { Observable} from 'rxjs/Observable'; 
import 'rxjs/add/observable/forkJoin'; 

console.log("Owk ooo let's play small with observables "); 

// this is just to form an asynchronous process 
asyncSimulator(data: number): Observable <any> { 
    return Observable.create(observer => { 
    setTimeout(() => { 
     observer.next("data to send can be object or anything" + data); 
     console.log("am done"); 
     observer.complete(); //to show we are done with our processing 
    }, 2000); 
    }) 
} 

/** 
call the all asynchronous process here, like so with Fork Join 
*/ 
Observable.forkJoin([ 
    this.asyncSimulator(1), 
    this.asyncSimulator(2), 
    this.asyncSimulator(3), 
    ]) 
    .subscribe(results => { 
    let async1 = result[0]; 
    let async2 = result[1]; 
    let async3 = result[1]; 
    console.log("results is an array", results); 
    }); 

・ホープ、このことができますように配列としてデータを返す実行forkJoinを、使用しています。