ConcatMap所中斷時錯誤在一個可觀察

Question

我下面加

`Observable.from(modifiedNodes) 
         .concatMap(node => { 

          return this.Model.setData(node); 
         }) 
         .subscribe(
         () => { 
          NodeSaved++; 
         }` 

這裏我的代碼，如果使用setData拋出錯誤任何中間節點，節點的下一個序列都沒有得到恢復。我們如何修改它，以便即使一個節點發生錯誤，也會執行下一個節點序列。我讀了'onerrorResumeNext'，但不知道如何在這裏使用它？ 任何幫助將是有用的。

使用setData（）是：

public setData(node: INode): Observable<Object>{} 

Answer 1

如果setData返回可觀察到的，你可以使用catch操作。這將收到內setData從出現的任何錯誤，如果你返回一個空觀察到的，concatMap將移動到下一個節點的順序：

import 'rxjs/add/observable/empty'; 
import 'rxjs/add/operator/catch'; 

Observable 
    .from(modifiedNodes) 
    .concatMap(node => this.Model 
    .setData(node) 
    .catch(error => Observable.empty()); 
) 
    .subscribe(() => { NodeSaved++; });