1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071 |
- 'use strict';
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- var _mapLimit = require('./mapLimit.js');
- var _mapLimit2 = _interopRequireDefault(_mapLimit);
- var _wrapAsync = require('./internal/wrapAsync.js');
- var _wrapAsync2 = _interopRequireDefault(_wrapAsync);
- var _awaitify = require('./internal/awaitify.js');
- var _awaitify2 = _interopRequireDefault(_awaitify);
- function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
- function groupByLimit(coll, limit, iteratee, callback) {
- var _iteratee = (0, _wrapAsync2.default)(iteratee);
- return (0, _mapLimit2.default)(coll, limit, (val, iterCb) => {
- _iteratee(val, (err, key) => {
- if (err) return iterCb(err);
- return iterCb(err, { key, val });
- });
- }, (err, mapResults) => {
- var result = {};
-
- var { hasOwnProperty } = Object.prototype;
- for (var i = 0; i < mapResults.length; i++) {
- if (mapResults[i]) {
- var { key } = mapResults[i];
- var { val } = mapResults[i];
- if (hasOwnProperty.call(result, key)) {
- result[key].push(val);
- } else {
- result[key] = [val];
- }
- }
- }
- return callback(err, result);
- });
- }
- exports.default = (0, _awaitify2.default)(groupByLimit, 4);
- module.exports = exports.default;
|