Brunobkr/llama.cpp_AlgMor24_github

1'use strict';2 3Object.defineProperty(exports, "__esModule", {4    value: true5});6 7var _once = require('./once.js');8 9var _once2 = _interopRequireDefault(_once);10 11var _iterator = require('./iterator.js');12 13var _iterator2 = _interopRequireDefault(_iterator);14 15var _onlyOnce = require('./onlyOnce.js');16 17var _onlyOnce2 = _interopRequireDefault(_onlyOnce);18 19var _wrapAsync = require('./wrapAsync.js');20 21var _asyncEachOfLimit = require('./asyncEachOfLimit.js');22 23var _asyncEachOfLimit2 = _interopRequireDefault(_asyncEachOfLimit);24 25var _breakLoop = require('./breakLoop.js');26 27var _breakLoop2 = _interopRequireDefault(_breakLoop);28 29function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }30 31exports.default = limit => {32    return (obj, iteratee, callback) => {33        callback = (0, _once2.default)(callback);34        if (limit <= 0) {35            throw new RangeError('concurrency limit cannot be less than 1');36        }37        if (!obj) {38            return callback(null);39        }40        if ((0, _wrapAsync.isAsyncGenerator)(obj)) {41            return (0, _asyncEachOfLimit2.default)(obj, limit, iteratee, callback);42        }43        if ((0, _wrapAsync.isAsyncIterable)(obj)) {44            return (0, _asyncEachOfLimit2.default)(obj[Symbol.asyncIterator](), limit, iteratee, callback);45        }46        var nextElem = (0, _iterator2.default)(obj);47        var done = false;48        var canceled = false;49        var running = 0;50        var looping = false;51 52        function iterateeCallback(err, value) {53            if (canceled) return;54            running -= 1;55            if (err) {56                done = true;57                callback(err);58            } else if (err === false) {59                done = true;60                canceled = true;61            } else if (value === _breakLoop2.default || done && running <= 0) {62                done = true;63                return callback(null);64            } else if (!looping) {65                replenish();66            }67        }68 69        function replenish() {70            looping = true;71            while (running < limit && !done) {72                var elem = nextElem();73                if (elem === null) {74                    done = true;75                    if (running <= 0) {76                        callback(null);77                    }78                    return;79                }80                running += 1;81                iteratee(elem.value, elem.key, (0, _onlyOnce2.default)(iterateeCallback));82            }83            looping = false;84        }85 86        replenish();87    };88};89 90module.exports = exports.default;