按順序訂閱一系列可觀察對象

Question

在這裏，我用rxjs中的forkJoin並行地訂閱了一系列觀察對象。但我想逐一訂閱，最好的解決方案是什麼？

下面是我的代碼：

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