0

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.

7

1 respuesta 1

0

Las suscripciones se cancelan siempre en caso de error. Puedes hacer dos cosas:

  • Volver a suscribirte al observable tras capturar un error con Observable.catch.
  • Usar el operador Observable.onErrorResumeNext para hacer que la subscripción automáticamente se renueve en caso de error:

    Observable.onErrorResumeNext(miObservable).subscribe(...)
    

Tu Respuesta

By clicking “Publica tu respuesta”, you agree to our terms of service and acknowledge you have read our privacy policy.

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.