/
var
/
www
/
cobraambalaj
/
node_modules
/
p-limit
/
/var/www/cobraambalaj/node_modules/p-limit
mkdir
upload
Name
Size
Mode
Actions
index.d.ts
1349
0644
edit
dl
rm
index.js
1114
0644
edit
dl
rm
license
1109
0644
edit
dl
rm
package.json
1949
0644
edit
dl
rm
readme.md
2894
0644
edit
dl
rm
Edit:
/var/www/cobraambalaj/node_modules/p-limit/index.js
(1114B)
'use strict'; const pTry = require('p-try'); 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;
Save
cmd:
run