Tengo una combinación de Promesas anidadas y suscripciones, y simplemente quiero hacer lo siguiente:
enfoque actual: Actualmente, mi bar () devuelve un Observable booleano, y manejo cada error por separado, para Promise a través de .catch, para el Observable rxjs a través del controlador de error:
foo(): void { this.bar.subscribe((data: boolean) => console.log('the function call bar() was ' + data)); } bar(): Observable<boolean> { let subject = new Subject<boolean>(); this.httpHandler.newFoo().subscribe( (data) => this.bar(data) .then((barData) => this.httpHandler.updateBar().subscribe( (barData2) => subject.next(true), (error) => subject.next(false))) .catch(err => subject.next(false)), (error) => subject.next(false)); return subject.asObservable(); }Aparentemente, esto es complicado y parece una exageración con el simple propósito de comprender si la llamada a la función bar() finalizó sin errores. ¿Hay una mejor manera de manejar los errores anidados por completo?
Gracias por adelantado
Creo que esto podría escribirse sucintamente como:
this.httpHandler.newFoo().pipe( switchMap(data => from(this.bar(data)).pipe( switchMap(() => this.httpHandler.updateBar().pipe( mapTo(true) ) ) ) ), catchError(() => of(false)) ) Para convertir una promesa en un observable, usa from() . Use switchMap() para hacer la transición entre los observables. Entonces solo es cuestión de encadenar tus llamadas:
this.httpHandler.newFoo() -> this.bar() -> this.httpHandler.updateBar()
y devolviendo true al final, de lo contrario, false por cualquier error.