Introducción a la Programación Reactiva

La programación reactiva es un paradigma que se centra en flujos de datos y la propagación de cambios. Es especialmente útil en aplicaciones que requieren manejar eventos asíncronos, y RxJS es una de las bibliotecas más populares en el ecosistema de JavaScript para lograrlo.

¿Qué es RxJS?

RxJS (Reactive Extensions for JavaScript) permite la programación reactiva usando Observables, que son una forma de trabajar con datos asíncronos. A diferencia de las Promesas, los Observables pueden emitir múltiples valores a lo largo del tiempo.

Instalación de RxJS

npm install rxjs

Para comenzar a utilizar RxJS, primero necesitamos instalar la biblioteca en nuestro proyecto de JavaScript o TypeScript.

Creación de un Observable

Los Observables son creados usando la función new Observable(). A continuación, se presenta un ejemplo básico:

import { Observable } from 'rxjs';

const observable = new Observable(subscriber => {
    subscriber.next('¡Hola desde RxJS!');
    subscriber.complete();
});

observable.subscribe({
    next(value) { console.log(value); },
    complete() { console.log('Observable completado'); }
});

En este código, se crea un nuevo Observable que emite un valor y luego se completa.

Operadores en RxJS

RxJS incluye una vasta colección de operadores para transformar, filtrar y combinar streams de datos. Algunos operadores comunes incluyen:

• map: Transforma los valores emitidos.
• filter: Filtra valores según una función dada.
• merge: Combina múltiples Observables en uno solo.

A continuación se muestra un ejemplo que utiliza map y filter:

import { of } from 'rxjs';
import { map, filter } from 'rxjs/operators';

const source = of(1, 2, 3, 4, 5);
const example = source.pipe(
    filter(x => x % 2 !== 0),
    map(x => x * 10)
);

example.subscribe(val => console.log(val)); // 10, 30, 50

Conclusión

RxJS proporciona herramientas poderosas para manejar datos y eventos asíncronos en aplicaciones JavaScript. Al dominar RxJS y la programación reactiva, puedes mejorar la eficiencia y usabilidad de tus aplicaciones modernizando la forma en que manejas la comunicación de datos.