const {interval, take, share} = rxjs;

const source = interval(1000).pipe(take(5));

const shared = source.pipe(share());

shared.subscribe((v) =>
  document.body.insertAdjacentHTML("beforeend", `<div>Subscriber 1: ${v}</div>`)
);

setTimeout(() => {
  shared.subscribe((v) =>
    document.body.insertAdjacentHTML(
      "beforeend",
      `<div>Subscriber 2: ${v}</div>`
    )
  );
}, 2000);