Tengo una capa de servicio responsable de manejar los datos y enviarlos a componentes que usan el mismo valor.

Necesito hacer solicitudes a la API, siempre que el valor sea isProcessed == false , hará 10 intentos cada medio segundo.

Si falla durante los intentos, solo hará 3 solicitudes más.

Si isProcessed == true , detuvo las solicitudes.

Toda la lógica está integrada, pero no puedo generar el último valor observable. Todas las respuestas son enviadas.

Todas las solicitudes son enviadas por observables, tanto falsas como verdaderas, pero solo necesito la última.

Aquí todas las respuestas de solicitudes llegan al componente, no solo la última

Servicio responsable de acceder a la API:

 public getPositionConsolidate(): Observable<PosicaoConsolidada> { return this.http.get<PosicaoConsolidada>(`${environment.api.basePosicaoConsolidada}/consolidado`) .pipe( map(res => res), retryWhen(genericRetryStrategy()), shareReplay(1), catchError(err => { console.log('Error in Position Consolidate', err); return throwError(err); }) ) }

Servicio responsable del tratamiento de los datos y su envío al componente:

 public positionConsolidate() { let subject = new BehaviorSubject<any>([]); this.api.getPositionConsolidate().subscribe(response => { if(response.hasProcessado == false) { for (let numberRequest = 0; numberRequest < 10; numberRequest++) { setTimeout(() => { //subject.next(this.api.getPosicaoConsolidada().subscribe()); this.api.getPositionConsolidate().subscribe(res => { subject.next(res) }) }, numberRequest * 500, numberRequest); } } else { retryWhen(genericRetryStrategy()), finalize(() => this.loadingService.loadingOff()) } }) return subject.asObservable() }

En componente:

 public ngOnInit() { this.coreState.positionConsolidate().subscribe(res => console.log(res)) }