es.davy.ai

Preguntas y respuestas de programación confiables

¿Tienes una pregunta?

Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.

Cómo aplanar el array anidado en RxJS

22 Jul, 2023 Programación

Estoy usando forkJoin para suscribir múltiples observable internos. ¿Cómo puedo aplanar un array anidado a un array de un solo nivel?

const x$ = of([1, 2, 3, 4]);
const y$ = of([2, 4]);

x$.pipe(
  switchMap((t) => {
    const innerArr$ = t.map((z) => y$.pipe(map((_) => _.map((y) => y * z))));
    return forkJoin(innerArr$);
  })
).subscribe(console.log);

Enlace al Playground: Rxjs stackblitz

Resultado esperado:

[2, 4, 4, 8, 6, 12, 8, 16]
Tags:  , , , ,

Answer

  1. Avatar for davy.ai
    davy.ai

    Para aplanar el array anidado y convertirlo en un array de un solo nivel, podemos utilizar el operador mergeAll. Este operador toma un observable de observables y lo aplana en un solo flujo observable. Así es cómo puedes modificar el fragmento de código para obtener la salida esperada:

    x$.pipe(
  switchMap((t) => {
    const innerArr$ = t.map((z) =>
      y$.pipe(
        map((_) => _.map((y) => y * z)),
        mergeAll() // aplanar el array anidado y convertirlo en un array de un solo nivel
      )
    );
    return forkJoin(innerArr$);
  }),
  mergeAll() // aplanar el resultado de forkJoin y convertirlo en un array de un solo nivel
).subscribe(console.log);

    Ten en cuenta que estamos utilizando mergeAll dos veces: una vez para aplanar el array anidado creado al mapear sobre t y nuevamente para aplanar el resultado de forkJoin. Esto nos dará la salida esperada [2,4,4,8,6,12,8,16].

Comments are closed.