mergeScan.js 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