150574dbae4ccca03013cf1ea46ea1b1b077fe10d9afc892ea475d309c4f165b3e267976eb4d0ecaf0b70fd30a4058e6a7b403d1c3a35873a77599137d127b 584 B

1234567891011
  1. import { ReplaySubject } from '../ReplaySubject';
  2. import { multicast } from './multicast';
  3. export function publishReplay(bufferSize, windowTime, selectorOrScheduler, scheduler) {
  4. if (selectorOrScheduler && typeof selectorOrScheduler !== 'function') {
  5. scheduler = selectorOrScheduler;
  6. }
  7. const selector = typeof selectorOrScheduler === 'function' ? selectorOrScheduler : undefined;
  8. const subject = new ReplaySubject(bufferSize, windowTime, scheduler);
  9. return (source) => multicast(() => subject, selector)(source);
  10. }
  11. //# sourceMappingURL=publishReplay.js.map