• Jobs
  • About Us
  • professionals
    • Home
    • Jobs
    • Courses and challenges
  • business
    • Home
    • Post vacancy
    • Our process
    • Pricing
    • Assessments
    • Payroll
    • Blog
    • Sales
    • Salary Calculator

0

91
Views
Capture el último valor de un observable con múltiples solicitudes

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.

ingrese la descripción de la imagen aquí

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)) }
almost 3 years ago · Juan Pablo Isaza
1 answers
Answer question

0

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

  • Primero, esto ejecuta la llamada API inicial.
  • Luego, según el resultado, ya sea...
    • Devuelve el resultado inicial
    • Llama a la API 10 veces cada 500 ms.
  • Implementa lo que tienes para retryWhen y finalize .
  • Devuelve el último resultado emitido.

Tampoco se suscriba a observables dentro de observables; para eso están los observables de orden superior, como concatMap .

almost 3 years ago · Juan Pablo Isaza Report
Answer question
Find remote jobs

Discover the new way to find a job!

Top jobs
Top job categories
Business
Post vacancy Pricing Our process Sales
Legal
Terms and conditions Privacy policy
© 2025 PeakU Inc. All Rights Reserved.

Andres GPT

Recommend me some offers
I have an error