Comment utiliser AsyncSubject ? #

Un "AsyncSubject" est un type spécial d'observable qui n'émet qu'une seule valeur à la fin de son exécution, et seulement aux observateurs qui se sont inscrits pendant l'exécution de l'observable.

Voici comment utiliser un AsyncSubject :

import { AsyncSubject } from 'rxjs'

const subject = new Rx.AsyncSubject();

subject.subscribe(console.log);

subject.next(1);
subject.next(2);
subject.next(3);
subject.complete(); // Dernière valeur émise, seulement ici 

Dans cet exemple, un nouvel AsyncSubject est créé en utilisant la syntaxe new AsyncSubject(). La méthode subscribe() est ensuite utilisée pour s'inscrire à l'AsyncSubject et spécifier les fonctions à exécuter lorsque des valeurs, des erreurs ou des complétions sont émises par l'AsyncSubject.

L'AsyncSubject n'émet des valeurs qu'aux observateurs qui se sont inscrits pendant l'exécution de l'AsyncSubject. Dans l'exemple ci-dessus, l'observateur s'est inscrit avant que l'AsyncSubject émette des valeurs, donc il recevra les valeurs 1, 2 et 3 lorsqu'elles seront émises. L'observateur également recevra la complétion lorsque l'AsyncSubject appelle la méthode complete().