Tengo el siguiente código:
this.ruleRepeatedValidate$.map((rule: ApiRule): ApiRulesOperation => {
return (rules: ApiRule[]) => {
let found: ApiRule = rules.find(t => t.rule === rule.rule);
if (found !== undefined) {
let exception: Error = {
name: "Regla repetida",
message: "No se puede repetir el nombre de la regla."
};
throw exception;
}
return rules;
}
}).subscribe(this.update$);
Lo que hace es validar si el nombre de una regla(Nombre, IP Inicial, IP Final) ya existe previamente. En caso que exista lanzo un error.
Quien captura el error:
this.rules$ = this.update$
.scan((rules: ApiRule[], operation: ApiRulesOperation) => operation(rules), initialRules)
.catch((exception: Error): Observable<ApiRule[]> => {
console.log("Error capturado: ", exception);
return Observable.just(initialRules);
})
.shareReplay(1);
Cuando se lanza el error, el ruleRepeatedValidate$:Subject pierde la suscripción a update$:BehaviorSubject.
He visto que existe Retry y RetryWhen pero no se como usarlos para resolver el problema.
¿Alguna ayuda?
Saludos.
throw exception;
?