@andrwj/fp/reduce.js

"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports["default"] = void 0;

/* eslint-disable */
var head = function head(iter) {
  return iter.next().value;
};

var empty =
/*#__PURE__*/
regeneratorRuntime.mark(function __empty() {
  return regeneratorRuntime.wrap(function __empty$(_context) {
    while (1) {
      switch (_context.prev = _context.next) {
        case 0:
        case "end":
          return _context.stop();
      }
    }
  }, __empty);
})();

var ensure = function ensure(iter) {
  return iter && iter[Symbol.iterator] ? iter[Symbol.iterator]() : empty;
};

var branchBy = function branchBy(value, f) {
  return value instanceof Promise ? value.then(f) : f(value);
};

var accumulate = function accumulate(acc, el, f) {
  return el instanceof Promise ? el.then(function (v) {
    return f(acc, v);
  }, function (e) {
    return Promise.reject(e);
  }) : f(acc, el);
};

var Reduce = function __reduce(f, acc, iter) {
  if (arguments.length === 1) return function () {
    for (var _len = arguments.length, iter = new Array(_len), _key = 0; _key < _len; _key++) {
      iter[_key] = arguments[_key];
    }

    return Reduce.apply(void 0, [f].concat(iter));
  };
  if (arguments.length === 2) return Reduce(f, head(iter = ensure(acc)), iter);
  iter = ensure(iter);
  var el;
  return branchBy(acc, function recursively(acc) {
    while (!(el = iter.next()).done) {
      acc = accumulate(acc, el.value, f);

      if (acc instanceof Promise) {
        return acc.then(recursively);
      }
    }

    return acc;
  });
};

var _default = Reduce;
exports["default"] = _default;