RxJS - Opérateur de multidiffusion publishBehavior

publishBehaviour utilise BehaviourSubject et renvoie ConnectableObservable. La méthode connect () doit être utilisée pour s'abonner à l'observable créée.

Syntaxe

publishBehaviour(defaultvalue)

Exemple

import { interval} from 'rxjs';
import { take, publishBehavior} from 'rxjs/operators';

let observer = interval(1000).pipe(
   take(5),
   publishBehavior(4)
);
const subscribe_one = observer.subscribe(
   x => console.log("Value from Sub1 = "+x)
);
const subscribe_two = observer.subscribe(
   x => console.log("Value from Sub2 = "+x)
);
observer.connect();
console.log("After 2 seconds");
setTimeout(() => {
   const subscribe_three = observer.subscribe(
      x => console.log("Value from Sub3 = "+x)
   );
}, 2000);

Production

La valeur par défaut sera affichée en premier et plus tard la valeur de l'observable.