share-replay-interval.ts

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

const source = log(interval(100), "source");
const shared = log(source.pipe(shareReplay(1)), "shared");
  
shared.pipe(
  takeUntil(timer(150))
).subscribe(
  value => console.log(`received: ${value}`)
);