Comment utiliser connectable sur RxJS ? #

Pour utiliser l'opérateur connectable de RxJS, vous devez d'abord importer l'opérateur à partir du module rxjs:

import { connectable } from 'rxjs';

Ensuite, vous pouvez utiliser l'opérateur en le passant à la méthode pipe d'un observable :

const observable = of(1, 2, 3).pipe(
  connectable()
);

L'opérateur connectable prend en paramètre une fonction qui sera appelée lorsque l'observable sera connecté à un abonné. Cela peut être utile pour déclencher des opérations asynchrones lorsque l'observable est connecté, comme lancer une requête HTTP :

const observable = of(1, 2, 3).pipe(
  connectable(() => {
    // Déclencher une requête HTTP ici...
  })
);

Pour que l'observable commence à émettre des valeurs, vous devez appeler la méthode connect sur l'observable :

const subscription = observable.connect();

Lorsque vous avez terminé de recevoir des valeurs de l'observable, vous pouvez annuler l'abonnement en appelant la méthode unsubscribe sur l'objet Subscription retourné par la méthode connect :

subscription.unsubscribe();