ConcatMap interrompu en cas d'erreur dans un observable

Question

J'ai ajouté mon code ci-dessous

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

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

Ici, si setdata génère une erreur pour un nœud intermédiaire, la séquence suivante de nœuds n'est pas reprise. Comment pouvons-nous le modifier pour que même en cas d'erreur pour un nœud, la séquence suivante de nœuds soit exécutée. J'ai lu des informations sur 'onerrorResumeNext' mais je ne suis pas sûr de savoir comment l'utiliser ici. Toute aide sera la bienvenue.

la fonction setdata() est telle que :

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

Answer 1

Si setData renvoie un observable, vous pouvez utiliser la méthode catch de l'opérateur. Il recevra toutes les erreurs provenant de l'intérieur de setData et si vous renvoyez un observable vide, concatMap passera au nœud suivant dans la séquence :

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