share-replay-timer.ts

import { timer } from "rxjs";
import { shareReplay, takeUntil } from "rxjs/operators";
import { log } from "./log";

const source = log(timer(100), "source");
const shared = log(source.pipe(shareReplay(1)), "shared");

shared.pipe(
  takeUntil(timer(50))
).subscribe(
  value => console.log(`first received: ${value}`)
);

setTimeout(() => shared.subscribe(
  value => console.log(`second received: ${value}`)
), 150);