diff --git a/dist/index.js b/dist/index.js index f1afd6c13..459343f74 100644 --- a/dist/index.js +++ b/dist/index.js @@ -111724,71 +111724,6 @@ function onceStrict (fn) { } -/***/ }), - -/***/ 57684: -/***/ ((module, __unused_webpack_exports, __nccwpck_require__) => { - -"use strict"; - -const pTry = __nccwpck_require__(80746); - -const pLimit = concurrency => { - if (!((Number.isInteger(concurrency) || concurrency === Infinity) && concurrency > 0)) { - return Promise.reject(new TypeError('Expected `concurrency` to be a number from 1 and up')); - } - - const queue = []; - let activeCount = 0; - - const next = () => { - activeCount--; - - if (queue.length > 0) { - queue.shift()(); - } - }; - - const run = (fn, resolve, ...args) => { - activeCount++; - - const result = pTry(fn, ...args); - - resolve(result); - - result.then(next, next); - }; - - const enqueue = (fn, resolve, ...args) => { - if (activeCount < concurrency) { - run(fn, resolve, ...args); - } else { - queue.push(run.bind(null, fn, resolve, ...args)); - } - }; - - const generator = (fn, ...args) => new Promise(resolve => enqueue(fn, resolve, ...args)); - Object.defineProperties(generator, { - activeCount: { - get: () => activeCount - }, - pendingCount: { - get: () => queue.length - }, - clearQueue: { - value: () => { - queue.length = 0; - } - } - }); - - return generator; -}; - -module.exports = pLimit; -module.exports["default"] = pLimit; - - /***/ }), /***/ 91855: @@ -114360,6 +114295,71 @@ module.exports.sync = (iterable, options) => { }; +/***/ }), + +/***/ 11305: +/***/ ((module, __unused_webpack_exports, __nccwpck_require__) => { + +"use strict"; + +const pTry = __nccwpck_require__(80746); + +const pLimit = concurrency => { + if (!((Number.isInteger(concurrency) || concurrency === Infinity) && concurrency > 0)) { + return Promise.reject(new TypeError('Expected `concurrency` to be a number from 1 and up')); + } + + const queue = []; + let activeCount = 0; + + const next = () => { + activeCount--; + + if (queue.length > 0) { + queue.shift()(); + } + }; + + const run = (fn, resolve, ...args) => { + activeCount++; + + const result = pTry(fn, ...args); + + resolve(result); + + result.then(next, next); + }; + + const enqueue = (fn, resolve, ...args) => { + if (activeCount < concurrency) { + run(fn, resolve, ...args); + } else { + queue.push(run.bind(null, fn, resolve, ...args)); + } + }; + + const generator = (fn, ...args) => new Promise(resolve => enqueue(fn, resolve, ...args)); + Object.defineProperties(generator, { + activeCount: { + get: () => activeCount + }, + pendingCount: { + get: () => queue.length + }, + clearQueue: { + value: () => { + queue.length = 0; + } + } + }); + + return generator; +}; + +module.exports = pLimit; +module.exports["default"] = pLimit; + + /***/ }), /***/ 96566: @@ -114367,7 +114367,7 @@ module.exports.sync = (iterable, options) => { "use strict"; -const pLimit = __nccwpck_require__(57684); +const pLimit = __nccwpck_require__(11305); class EndError extends Error { constructor(value) {