98145baace62ec10bb71a240510f973cf2f2d673dc00dbe0874e536602c103135ebc690b4cf4491f65f7993652f532b7a0b765d77636433af6f9d2f7e3b16a 485 B

1234567891011
  1. import { operate } from '../util/lift';
  2. import { mergeInternals } from './mergeInternals';
  3. export function mergeScan(accumulator, seed, concurrent = Infinity) {
  4. return operate((source, subscriber) => {
  5. let state = seed;
  6. return mergeInternals(source, subscriber, (value, index) => accumulator(state, value, index), concurrent, (value) => {
  7. state = value;
  8. }, false, undefined, () => (state = null));
  9. });
  10. }
  11. //# sourceMappingURL=mergeScan.js.map