Business
Jobs
  • About Us
  • Solutions
    • Job Postings
      Post your job and receive qualified candidates in 48h.
    • Candidate Assessments
      500+ technical and psychological tests, plus anti-fraud.
    • Headhunting
      Tailor-made executive search from start to finish.
    • Payroll + EOR
      Payroll dispersal and EOR across 15+ LATAM countries.
  • Pricing
  • Jobs

0

141
Views
RxJS usa emisiones combinadas tal como vienen

Tengo un componente Angular que necesita datos de tres fuentes separadas, s1$ , s2$ y s3$ . Estas son, de hecho, llamadas API.

Estoy creando un valor combinado llamado pageData$ , esencialmente un objeto que contendrá los tres valores para la plantilla.

También quiero que los datos se muestren tal como vienen en lugar de esperar a que se completen todas las solicitudes.

Probé el mergeMap , pero me di cuenta de que esto no funcionaría porque cada Observable anidado necesita emitir al menos una vez para que se emita el resultado mapeado. Dado que estas tres fuentes son, de hecho, solicitudes HTTP, esto significa esencialmente que estoy obteniendo un comportamiento similar al de forkJoin .

Entonces, probé con combineLatest , pero aún se comporta igual. Aquí está el código:

 constructor(route: ActivatedRoute) { // Attempt with mergeMaps: this.pageData$ = route.params.pipe( // I get some Id from route parameters switchMap(params => s1$.pipe( mergeMap(s1 => s2$.pipe( mergeMap(s2 => s3$.pipe( map(s3 => { return { data1: s1, data2: s2, data3: s3 }; }) )) )) )) ); // Attempt with combineLatest: this.pageData$ = route.params.pipe( switchMap(params => this.getPageData$(params['id'])) ); } private getPageData$(eventId: string): Observable<EventGroupPageData> { return combineLatest([ s1$, s2$, s3$ ]).pipe( map(([s1, s2, s3]) => { return { data1: s1, data2: s2, data3: s3 }; }) ); }

En la plantilla, estoy usando una async pipe para desempaquetar los valores y representar la interfaz de usuario:

 <div *ngIf="pageData$ | async as pageData"> render... </div>

Ahora, me gustaría poder representar cada uno de los tres elementos tan pronto como ese dato en particular provenga de la API, lo que parece que no puedo lograr.

¿Algunas ideas?

about 4 years ago · Juan Pablo Isaza
1 answers
Answer question

0

Creo que puede usar combineLatest , pero debe comenzar cada observable con un valor de inicio, por ejemplo, puede ser un operador startWith , hay un ejemplo para usted: Stackblitz

about 4 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 Sales
Legal
Terms and conditions Privacy policy
© 2026 PeakU Inc. All Rights Reserved.
Andres GPT
Show me some job opportunities
There's an error!