Estudio de RxJS

• Observables y operadores
• Programación reactiva
• Soporte para programación funcional

• Tratamiento de eventos de usuario
• Operaciones asíncronas
• Streaming de datos

Instalación: npm i rxjs

import { of, map } from 'rxjs';
of(1, 2, 3).pipe(map((n) => n * 2)).subscribe(console.log);

1. Contador de clics

Cuenta clics con fromEvent y acumula.

import { fromEvent, scan } from 'rxjs';

const clics = fromEvent(document, 'click').pipe(
  scan((acc) => acc + 1, 0)
);
clics.subscribe((n) => console.log('Clics:', n));

2. Debounce de búsqueda

Busca solo tras pausa de escritura.

import { fromEvent, debounceTime, map, distinctUntilChanged } from 'rxjs';

const input = document.querySelector('input');
fromEvent(input, 'input').pipe(
  map((e) => e.target.value),
  debounceTime(300),
  distinctUntilChanged()
).subscribe((q) => console.log('Buscar:', q));