オブザーバブル配列への順次サブスクリプション

Question

ここでは、rxjsのforkJoinを使用して、オブザーバブルオブジェクトの配列を並行してサブスクライブしました。しかし、私はそれらを1つずつ購読したいと思います。何が最善の解決策になりますか？以下は

は私のコードです：

var observables = []; 

Observable.forkJoin(observables) 
    .subscribe(() => { 
     this.msgs = []; 
     this.msgs.push({ 
      severity: 'success', 
      summary: 'Saved Successfully' 
     }); 
     this.onSaveComplete(); 
    }, (error: any) => this.errorMessage = <any>error); 
}, (error: any) => this.errorMessage = <any>error); 

Answer 1

forkJoinの代わりに、observablesの配列を順番に購読する必要があることを意味します。 mergeとconcatは、この場合に行く方法です。あなたの場合、mergeとconcatを使用している場合は、あなたのコードを変更し、観測オブジェクトの配列の始めにスプレッド演算子を使用します。

var observables = []; 
Observable.concat(...observables) 
      .subscribe(() => { 
       this.msgs = []; 
       this.msgs.push({ 
        severity: 'success', 
        summary: 'Saved Successfully' 
       }); 
       this.onSaveComplete(); 
      }, (error: any) => this.errorMessage = <any>error); 
    }, (error: any) => this.errorMessage = <any>error); 

Answer 2

は依存要求のシリーズを作るためにthe switchMap operatorを使用してください。エラーが伝播し、チェーンの最後でエラーをキャッチしたり処理したりすることができます。

return this.http.get('something/1') 
    .switchMap(res1 => { 
    // use res1 if you need it 
    return this.http.get('something/2') 
    }) 
    .switchMap(res2 => { 
    // use res2 if you need it 
    return this.http.get('something/3') 
    }) 
    .subscribe(res3 => { 
    // use the final response 
    console.log(res3) 
    })