index.js
995 Bytes
module.exports=(()=>{"use strict";var e={684:(e,t,r)=>{const n=r(746);const o=e=>{if(!((Number.isInteger(e)||e===Infinity)&&e>0)){return Promise.reject(new TypeError("Expected `concurrency` to be a number from 1 and up"))}const t=[];let r=0;const o=()=>{r--;if(t.length>0){t.shift()()}};const i=(e,t,...i)=>{r++;const s=n(e,...i);t(s);s.then(o,o)};const s=(n,o,...s)=>{if(r<e){i(n,o,...s)}else{t.push(i.bind(null,n,o,...s))}};const u=(e,...t)=>new Promise(r=>s(e,r,...t));Object.defineProperties(u,{activeCount:{get:()=>r},pendingCount:{get:()=>t.length},clearQueue:{value:()=>{t.length=0}}});return u};e.exports=o;e.exports.default=o},746:e=>{const t=(e,...t)=>new Promise(r=>{r(e(...t))});e.exports=t;e.exports.default=t}};var t={};function __nccwpck_require__(r){if(t[r]){return t[r].exports}var n=t[r]={exports:{}};var o=true;try{e[r](n,n.exports,__nccwpck_require__);o=false}finally{if(o)delete t[r]}return n.exports}__nccwpck_require__.ab=__dirname+"/";return __nccwpck_require__(684)})();