Subscribe
Dans l'exemple ci-dessous nous allons créer un observable à l'aide de la fonction interval
qui produit une valeur auto-incrémentée de façon régulière.
import { interval } from 'rxjs';
const data$ = interval(1000);
Tant qu'on ne s'inscrit pas à l'"observable", il ne se passe rien car cet observable est "lazy“.
La convention de nommage est de suffixer les "observables" avec $
.
Observable.subscribe
Observable.subscribe
Le point commun entre tous les "observables" est la méthode subscribe
qui permet de souscrire à un Observable
et être notifié des nouvelles valeurs, des erreurs ou de la fin du "stream".
import { interval } from 'rxjs';
const data$ = interval(1000);
data$.subscribe(value => console.log(value));

Nous pouvons ensuite ajouter les "callbacks" de capture d'"erreur" ou de fin du "stream" en passant un objet à la méthode subscribe avec les trois callbacks suivantes : next
, error
et complete
.
data$.subscribe({
next: value => console.log(value),
error: err => console.error(err),
complete: () => console.log('DONE!')
});
Dernière mise à jour