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

rxjs-7_share.ts

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

const shared$ = zip(interval(1000), of("A", "B", "C", "D", "E")).pipe(
  map(([, char]) => char),
  share({
    connector: () => new ReplaySubject(3),
    resetOnComplete: false,
    resetOnError: false,
    resetOnRefCountZero: false
  })
);

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