medium-rxjs-publish-multicast.ts

import { defer, Observable, of, Subject } from "rxjs";
import { multicast } from "rxjs/operators";

const source = defer(() => of(
  Math.floor(Math.random() * 100)
));

function observer(name: string) {
  return {
    next: (value: number) => console.log(`observer ${name}: ${value}`),
    complete: () => console.log(`observer ${name}: complete`)
  };
}

const m = source.pipe(
  multicast(new Subject<number>())
);
m.subscribe(observer("a"));
m.subscribe(observer("b"));
m.connect();