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

0

183
Views
¿Proceder condicionalmente al próximo mergeMap? [ rxjs.Observable]

Me gustaría convertir mis Observables anidados con el uso de pipe, map, mergeMap, sin embargo, hay condiciones después de las cuales quiero que continúe

observableFunction es un Observable que recorre una matriz, una vez que finaliza, puede continuar para usar los datos manipulados

 observableFunction(par1,par2) .subscribe((resp) => { i++; //do stuff, manipulate resp const lastIteration = someArray.length == i; if (lastIteration) { //do stuff observableFunction(par1a, par2a) .subscribe((resp) => { observableHandleFunction(resp) .subscribe((handledData) => { h++; const lastIterationSub = someNestedArray.length == h; //do stuff, manipulate handledData if (lastIterationSub) { console.log("done"); }); }); } });

¿Cómo puedo convertirlo para que parezca más fácil de leer usando las funciones de rxjs que están destinadas a usarse en este escenario? ¿Te gusta aplicar condiciones a mergeMap?

 observableFunction(par1,par2) .pipe( mergeMap((res1) => { //do stuff CONDITION={ return observableFunction(par1a,par2a) } }), mergeMap((res2) => return observableHandleFunction(res2)) ) .subscribe((res3) => { h++; //do stuff const lastIterationSub = someNestedArray.length == h; if (lastIterationSub) { console.log("done"); } });

Con una solución como esta, no funcionará con la condición, lo que generará un error.

almost 3 years ago · Juan Pablo Isaza
1 answers
Answer question

0

En primer lugar, anidar bloques de subscribe siempre es una mala idea.

Si su observableFunction emite valores únicos (en lugar de una matriz completa a la vez) y cuando termina emite un valor completo, puede usar el operador toArray . Asi que:

 observableFunction(par1,par2) .pipe(toArray()) // Here you will have an array of items, now you can proceed with something like: observableFunction(par1,par2) .pipe( toArray(), mergeMap(array => { // If neccesary you can do the same here etc }))
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