Programmation réactive en JavaScript (Node.js) : la bibliothèque RxJS

Programmation réactive en JavaScript (Node.js) avec RxJS

\n\n

La programmation réactive est un paradigme orienté vers les flux de données asynchrones et la propagation des changements. Dans l'écosystème JavaScript (Node.js), l'une des bibliothèques les plus puissantes pour implémenter ce paradigme est RxJS (Reactive Extensions for JavaScript). Elle fournit des outils pour travailler avec des Observable (séquences observables), permettant aux développeurs de traiter efficacement les événements, les requêtes HTTP, les minuteurs et autres sources de données asynchrones.

\n\n

Concepts fondamentaux de RxJS

\n

RxJS repose sur trois composants clés :

\n

\n
• Observable (Objet observable) — représente un flux de données qui peut générer des valeurs au fil du temps.
\n
• Observer (Observateur) — objet qui s'abonne à un Observable et réagit à l'arrivée de nouvelles données (next), aux erreurs (error) ou à la fin du flux (complete).
\n
• Subscription (Abonnement) — résultat de l'appel de la méthode subscribe(). Permet de gérer le cycle de vie de l'abonnement (par exemple, l'annuler).
\n

\n

Les opérateurs jouent également un rôle important — ce sont des fonctions pures qui permettent de transformer, filtrer, fusionner et combiner des flux de données.

\n\n

Installation et configuration

\n

Pour utiliser RxJS dans un projet Node.js, il suffit d'installer le package via npm :

\n

npm install rxjs

\n

Après l'installation, la bibliothèque est prête à être utilisée. Importez les composants nécessaires :

\n

const { Observable, of, from, interval } = require('rxjs');\nconst { map, filter, take } = require('rxjs/operators');

\n\n

Création d'un Observable

\n

Il existe plusieurs façons de créer des flux de données. Voici les méthodes de base :

\n\n

1. Création à partir d'un tableau

\n

const { from } = require('rxjs');\n\nconst numbers$ = from([1, 2, 3, 4, 5]);\nnumbers$.subscribe({\n    next: value => console.log(`Reçu : ${value}`),\n    complete: () => console.log('Flux terminé')\n});

\n

Résultat de l'exécution :

\n

Reçu : 1\nReçu : 2\nReçu : 3\nReçu : 4\nReçu : 5\nFlux terminé

\n\n

2. Génération périodique de valeurs

\n

const { interval } = require('rxjs');\nconst { take } = require('rxjs/operators');\n\nconst timer$ = interval(1000).pipe(\n    take(4) // limite à 4 valeurs\n);\n\ntimer$.subscribe({\n    next: value => console.log(`Tick ${value}`),\n    complete: () => console.log('Minuteur terminé')\n});

\n

Sortie (avec un intervalle de 1 seconde) :

\n

Tick 0\nTick 1\nTick 2\nTick 3\nMinuteur terminé

\n\n

Travailler avec les opérateurs

\n

Les opérateurs sont le cœur de RxJS. Ils permettent de transformer les données à la volée. Voici deux opérateurs populaires :

\n

\n
• map — transforme chaque valeur du flux.
\n
• filter — ne laisse passer que les valeurs qui satisfont une condition.
\n

\n\n

const { of } = require('rxjs');\nconst { map, filter } = require('rxjs/operators');\n\nconst source$ = of(1, 2, 3, 4, 5, 6);\n\nsource$.pipe(\n    filter(value => value % 2 === 0), // ne garde que les pairs\n    map(value => value * 10)          // multiplie chaque valeur par 10\n).subscribe({\n    next: value => console.log(`Résultat : ${value}`),\n    complete: () => console.log('Terminé')\n});

\n

Résultat :

\n

Résultat : 20\nRésultat : 40\nRésultat : 60\nTerminé

\n\n

Gestion des erreurs dans les flux réactifs

\n

RxJS fournit des mécanismes intégrés pour la gestion des erreurs. Par exemple, l'opérateur catchError permet d'intercepter une exception et de continuer l'exécution :

\n

const { throwError, of } = require('rxjs');\nconst { catchError } = require('rxjs/operators');\n\nconst error$ = throwError(() =>