Esto debería ser más o menos equivalente:

 this.service.save(body).pipe( mergeMap(resp => this.dialog.confirmation({ message: 'save object successfully!' }).pipe( // This filter acts like your `if(ok)` statement. There's no // else block, so if it's not okay, then nothing happens. The // view isn't updated etc. filter(ok => !!ok), mapTo(resp) ) ), tap(resp => { this.pro.status = resp.status; // If the following line mutates service/global state, // it probably won't work as expected this.loadingData(resp); }), mergeMap(_ => forkJoin([ this.service.getSummary(this.id), this.service.getCost(this.id) ])) ).subscribe([view, list]) => { this.view = view; this.list = list; });

Puede simplificarlo usando los operadores RxJS , como el siguiente:

 // import { EMPTY, forkJoin } from 'rxjs'; // import { map, mergeMap } from 'rxjs/operators'; this.service .save(body) .pipe( mergeMap((result) => // Merge the main observable with the dialog confirmation one.. // and map it to an object that contains the result from both observables. this.dialog .confirmation({ message: 'save object successfully!' }) .pipe(map((confirmed) => ({ result, confirmed }))) ), mergeMap(({ result, confirmed }) => { if (confirmed) { this.pro.status = result.status; this.loadingData(result); const s1 = this.service.getSummary(this.id); const s2 = this.service.getCost(this.id); return forkJoin([s1, s2]); } // Don't emit any value, if the dialog is not confirmed: return EMPTY; }) ) .subscribe(([r1, r2]) => { this.view = r1; this.list = r2; });

Nota: Para manejar las fugas de memoria, se recomienda encarecidamente unsubscribe de baja del observable cuando ya no lo necesite, y esto se puede lograr en función de sus casos de uso, como asignar el resultado de la función de subscribe a una variable de Subscription y llamar a unsubscribe de baja en el gancho del ciclo de vida de ngOnDestroy , o usando un Subject con el operador takeUntil y llamando a las funciones next / complete en ngOnDestroy .

Y aquí está cómo usar el método de cancelación de unsubscribe , por ejemplo:

 // import { Subscription } from 'rxjs'; @Component({...}) export class AppComponent implements OnInit, OnDestroy { subscription: Subscription ngOnInit(): void { this.subscription = this.service.save(body) // >>> pipe and other RxJS operators <<< .subscribe(([r1, r2]) => { this.view = r1; this.list = r2; }); } ngOnDestroy() { this.subscription.unsubscribe() } }

Puede leer más sobre eso aquí: https://blog.bitsrc.io/6-ways-to-unsubscribe-from-observables-in-angular-ab912819a78f