ConcatMapがsetDataメソッドは、任意の中間ノードのエラーを投げている場合は、エラーが1観測可能

Question

に、私はここで

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

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

の下に私のコードを追加していたときにinterupted、ノードの次のシーケンスが再開取得されていません。 1つのノードのエラーであっても、ノードの次のシーケンスが実行されるように、どのように変更できますか？私は 'onerrorResumeNext'について読んだけど、ここでそれを使う方法はわからない？ ヘルプが便利です。 setDataが観測を返す場合、あなたはcatch演算子を使用することができます

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

Answer 1

：

のsetData（）がようです。それはsetData内からスローされたすべてのエラーを受け取ることになりますし、あなたが空に観察を返す場合、concatMapは、シーケンス内の次のノードに移動します：あなたがに含める必要がありますので、答えは、どのような `setData`リターンに依存する

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