No tienes acceso a esta clase

¡Continúa aprendiendo! Únete y comienza a potenciar tu carrera

Documentación de RxJS

32/36
Recursos

Aportes 5

Preguntas 0

Ordenar por:

¿Quieres ver más aportes, preguntas y respuestas de la comunidad?

Funcionamiento de concatMap
concatMap tiene un funcionamiento similar a mergeMap, excepto que concatMap, espera que el observable interno envie un mensaje de complete, para recibir el siguiente valor de entrada.

import { fromEvent, concatMap, mergeMap, interval, take } from "rxjs";

const clicks = fromEvent(document, "click");
const result = clicks.pipe(mergeMap((ev) => interval(500).pipe(take(3))));
result.subscribe((x) => console.log(x));

Output si dieramos 2 clicks de forma consecutiva:

0
1
2
0
1
2

Output si remplazamos concatMap con mergeMap, dando 2 clicks de forma consecutiva:

0
0
1
1
2
2 

No había visto esa forma de navegar en la documentación, muy interesante ese asistente que tiene

forkJoin es un operador en RxJS que combina múltiples observables en un solo observable y emite un único valor que contiene los valores finales de todos los observables combinados cuando todos los observables han emitido su último valor y han completado.

En otras palabras, forkJoin espera a que todos los observables se completen y luego emite un único valor que contiene un arreglo con los últimos valores emitidos por cada observable combinado.

import { forkJoin, of, timer } from 'rxjs';
import { delay } from 'rxjs/operators';

const observable1 = of('Valor 1').pipe(delay(1000)); // Emite 'Valor 1' después de 1 segundo
const observable2 = of('Valor 2').pipe(delay(2000)); // Emite 'Valor 2' después de 2 segundos
const observable3 = of('Valor 3').pipe(delay(3000)); // Emite 'Valor 3' después de 3 segundos

forkJoin({
  observable1,
  observable2,
  observable3
}).subscribe({
  next: (result) => console.log('Resultado:', result),
  error: (error) => console.error('Error:', error),
  complete: () => console.log('Completado')
});

ame el operator decision tree, me dijo lo que queria y tenia que hacer.

Muy buena documentacion.