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)) }
La parte más fácil de responder a su pregunta es que si solo desea la última emisión de un observable, simplemente use el último operador. Sin embargo, la forma en que has escrito las cosas hace que sea difícil de incorporar. Lo siguiente refactoriza su código como una secuencia única sin ninguna estructura de control que no sea rxjs.
public positionConsolidate() { return this.api.getPositionConsolidate().pipe( concatMap(res => iif(() => res.hasProcessado, of(res), interval(500).pipe( take(10), concatMap(() => this.api.getPositionConsolidate()) ) )), retryWhen(genericRetryStrategy()), finalize(() => this.loadingService.loadingOff()), last() ); }
Qué esta pasando
Tampoco se suscriba a observables dentro de observables; para eso están los observables de orden superior, como concatMap .