[What's New in RxJS 7] RxJS 6 shareReplay #blog #rxjs

rxjs-6_shareReplay.ts

import { interval, of, zip } from "rxjs";
import { map, shareReplay } from "rxjs/operators";

const shared$ = zip(interval(1000), of("A", "B", "C", "D", "E")).pipe(
  map(([, char]) => char),
  shareReplay({ refCount: true, bufferSize: 3 })
);

shared$.subscribe(console.log);
// (~1s apart) A, B, C, D, E

setTimeout(() => shared$.subscribe(console.log), 6000);
// (after ~6s, all at once) C, D, E