Skip to content
On this page

Comment utiliser ReplaySubject ?

Un "ReplaySubject" est un type spécial d'observable qui stocke toutes les valeurs produites par l'observable, puis les émet immédiatement aux observateurs qui s'inscrivent à l'observable.

Par exemple, si vous avez un observable qui produit des mises à jour en temps réel, vous pouvez utiliser un ReplaySubject pour stocker les dernières valeurs produites et les émettre immédiatement aux observateurs qui s'inscrivent à l'observable.

Voici un exemple montrant comment utiliser un ReplaySubject pour stocker les dernières valeurs produites par un observable :

js
import { ReplaySubject } from 'rxjs'

const subject = new Rx.ReplaySubject(2);

subject.subscribe(console.log);

subject.next(1);
subject.next(2);
subject.next(3);
subject.complete();

Dans cet exemple, un ReplaySubject est créé avec un paramètre 2, ce qui signifie que le ReplaySubject stocke les deux dernières valeurs produites par l'observable. La méthode next() est utilisée pour émettre les valeurs 1, 2 et 3 depuis l'observable, puis la méthode complete() est utilisée pour indiquer que l'observable a terminé son exécution.