mergeScan.js 580 B

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