diff options
Diffstat (limited to 'src/common-util')
| -rw-r--r-- | src/common-util/sugar.js | 29 |
1 files changed, 0 insertions, 29 deletions
diff --git a/src/common-util/sugar.js b/src/common-util/sugar.js index fba06d76..354cf5cc 100644 --- a/src/common-util/sugar.js +++ b/src/common-util/sugar.js @@ -395,35 +395,6 @@ export function queue(functionList, queueSize = 50) { return promiseList; } -export function wrapQueue(fn, queueSize = 50) { - if (queueSize === 0) return fn; - - let running = 0; - let resume = []; - - let proceed = (...args) => { - running++; - return Promise.try(fn, ...args).finally(() => { - running--; - if (resume.length) { - resume.shift()(); - } - }); - }; - - return (...args) => { - if (running === queueSize) { - return new Promise(resolve => { - resume.push(resolve); - }).then(() => { - return proceed(...args); - }); - } else { - return proceed(...args); - } - }; -} - export function delay(ms) { return new Promise((res) => setTimeout(res, ms)); } |