角度2の約束/観測可能なチェーン2イベント？

Question

観測可能または約束は角2で以下のユースケースで使用することができる場合、私は思ったんだけど：

2つの非同期アップロードタスクがあります。私はどのように私は両方のタスクを検出することができます知りたいのですが完了です。

マイアップロードタスク（約束に実装されますが、必要であれば、それは簡単にに観察に変更されます）は、このようなものです：

約束または のいずれかで一緒にこれらの2つのイベントがチェーンにどのよう

myService.upload('upload1').then(() => { 
}) 

myService.upload('upload2').then(() => { 
}) 

私は両方のタスクが完了している知っているので、を観察する？ありがとう

Answer 1

completeで動作が実行されます。

Rx.Observable.merge(
    myService.upload('upload1'), 
    myService.upload('upload2').subscribe({complete:() => { ... }); 

あなたはアンギュラ1.xから$ q.allと同等です

Rx.Observable.merge(
    myService.upload('upload1'), 
    myService.upload('upload2') 
.take(2) 
.subscribe({complete:() => { ... }); 

Answer 2

Combining Operatorsのいずれかを観測値とともに使用できます。すべてのソースストリームが閉じているときObservable.zip()、例えば、約束...

Observable.zip(
    first, 
    second, 
    function (firstResolvedValue, secondResolvedValue) { 
     return firstResolvedValue && secondResolvedValue; 
    } 
) 

zip accepts a variable number of Observables or Promises as parameters, followed by a function that accepts one item emitted by each of those Observables or resolved by those Promises as input and produces a single item to be emitted by the resulting Observable.

Answer 3

使用forkJoin、（a、bは観測されている）を待つ結果の最大数を設定したい場合：

Rx.Observable.forkJoin([a,b]).subscribe(t=> { 
     var firstResult = t[0]; 
     var secondResult = t[1]; 
}); 

Answer 4

あなたは引数配列内の約束のすべてが解決したときに解決する新しい約束を返すPromise.allを使用することができます。

Promise.all([myService.upload('upload1'), myService.upload('upload2')]).then(() => { 
    // ... 
}); 

注意、あなたのmyService.upload方法は約束ではなく、約束を返した場合は、戻り値をこのようにアクセスできます。

Promise.all([myService.upload('upload1'), myService.upload('upload2')]) 
    .then((retValue1, retValue2) => { 
    // ... 
});