workerpool - npm Package Compare versions

Comparing version 5.0.3 to 5.0.4

dist/worker.js

@@ -7,4 +7,4 @@ /**
  *
- * @version 5.0.3
- * @date    2019-12-23
+ * @version 5.0.4
+ * @date    2019-12-31
  *
@@ -11,0 +11,0 @@ * @license

dist/workerpool.js

@@ -7,4 +7,4 @@ /**
  *
- * @version 5.0.3
- * @date    2019-12-23
+ * @version 5.0.4
+ * @date    2019-12-31
  *
@@ -131,7 +131,7 @@ * @license
 var isNode = function (nodeProcess) {
-    return (
-        typeof nodeProcess !== 'undefined' &&
-        nodeProcess.versions != null &&
-        nodeProcess.versions.node != null
-    );
+  return (
+    typeof nodeProcess !== 'undefined' &&
+    nodeProcess.versions != null &&
+    nodeProcess.versions.node != null
+  );
 }
@@ -142,16 +142,26 @@ module.exports.isNode = isNode
 module.exports.platform = typeof process !== 'undefined' && isNode(process)
-    ? 'node'
-    : 'browser';
+  ? 'node'
+  : 'browser';
 
 // determines whether the code is running in main thread or not
+// note that in node.js we have to check both worker_thread and child_process
+var worker_threads = tryRequireFoolWebpack('worker_threads');
 module.exports.isMainThread = module.exports.platform === 'node'
-    ? !process.connected
-    : typeof Window !== 'undefined';
+  ? ((!worker_threads || worker_threads.isMainThread) && !process.connected)
+  : typeof Window !== 'undefined';
 
 // determines the number of cpus available
 module.exports.cpus = module.exports.platform === 'browser'
-    ? self.navigator.hardwareConcurrency
-    : requireFoolWebpack('os').cpus().length;
+  ? self.navigator.hardwareConcurrency
+  : requireFoolWebpack('os').cpus().length;
 
+function tryRequireFoolWebpack (module) {
+  try {
+    return requireFoolWebpack(module);
+  } catch(err) {
+    return null
+  }
+}
 
+
 /***/ }),
@@ -158,0 +168,0 @@ /* 1 */

dist/workerpool.map

@@ -1,1 +0,1 @@
-{"version":3,"sources":["0"],"names":["root","factory","exports","module","define","amd","self","this","modules","__webpack_require__","isNode","nodeProcess","versions","node","requireFoolWebpack","platform","process","isMainThread","connected","Window","cpus","navigator","hardwareConcurrency","length","Promise","handler","parent","me","SyntaxError","_onSuccess","_onFail","resolved","rejected","pending","_process","onSuccess","onFail","push","then","resolve","reject","s","_then","f","_resolve","result","forEach","fn","_reject","error","cancel","CancellationError","timeout","delay","timer","setTimeout","TimeoutError","always","clearTimeout","callback","res","message","stack","Error","prototype","all","promises","remaining","results","p","i","defer","resolver","promise","constructor","name","eval","environment","pool","script","options","worker","methods","add","WorkerHandler","DEBUG_PORT_ALLOCATOR","Pool","workers","tasks","nodeWorker","console","warn","forkArgs","forkOpts","debugPortStart","workerType","maxQueueSize","Infinity","maxWorkers","isNumber","isInteger","TypeError","validateMaxWorkers","Math","max","minWorkers","validateMinWorkers","_ensureMinWorkers","_boundNext","_next","bind","ensureWorkerThreads","value","round","exec","method","params","Array","isArray","task","originalTimeout","indexOf","call","String","proxy","arguments","slice","_getWorker","shift","catch","terminated","_removeWorker","busy","_createWorkerHandler","releasePort","debugPort","terminate","_removeWorkerFromList","index","splice","force","removeWorker","termPromise","terminateAndNotify","clear","stats","totalWorkers","busyWorkers","filter","idleWorkers","pendingTasks","activeTasks","nextAvailableStartingAt","WorkerThreads","tryRequireWorkerThreads","ensureWebWorker","Worker","code","setupBrowserWorker","isBrowserWorker","on","event","addEventListener","data","send","postMessage","setupWorkerThreadWorker","stdout","stderr","isWorkerThread","kill","disconnect","setupProcessWorker","child_process","fork","isChildProcess","resolveForkOptions","opts","processExecArgv","execArgv","join","inspectorActive","debugBrk","arg","Object","assign","concat","_options","onError","id","terminating","terminationHandler","processing","undefined","create","__dirname","Blob","window","URL","createObjectURL","blob","type","getDefaultWorker","setupWorker","ready","requestQueue","response","obj","temp","props","keys","objectToError","exitCode","signalCode","spawnargs","spawnfile","lastId","request","_tryRequireWorkerThreads","_setupProcessWorker","_setupBrowserWorker","_setupWorkerThreadWorker","DebugPortAllocator","ports","starting","port","parentPort","exit","convertError","getOwnPropertyNames","reduce","product","defineProperty","enumerable","isPromise","run","args","apply","err","register","hasOwnProperty","installedModules","m","c","d","getter","o","get","r","Symbol","toStringTag","t","mode","__esModule","ns","key","n","object","property","moduleId","l"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;CAyBA,SAA2CA,EAAMC,GAC1B,iBAAZC,SAA0C,iBAAXC,OACxCA,OAAOD,QAAUD,IACQ,mBAAXG,QAAyBA,OAAOC,IAC9CD,OAAO,aAAc,GAAIH,GACC,iBAAZC,QACdA,QAAoB,WAAID,IAExBD,EAAiB,WAAIC,IARvB,CASoB,oBAATK,KAAuBA,KAAOC,KAAO,WAChD,OAA0BC,EAsFhB,CAEJ,SAAUL,EAAQD,EAASO,GAKpB,SAATC,EAAmBC,GACnB,YAC2B,IAAhBA,GACiB,MAAxBA,EAAYC,UACiB,MAA7BD,EAAYC,SAASC,KAP7B,IAAIC,EAAqBL,EAAoB,GAU7CN,EAAOD,QAAQQ,OAASA,EAGxBP,EAAOD,QAAQa,SAA8B,oBAAZC,SAA2BN,EAAOM,SAC7D,OACA,UAGNb,EAAOD,QAAQe,aAA2C,SAA5Bd,EAAOD,QAAQa,UACtCC,QAAQE,UACS,oBAAXC,OAGbhB,EAAOD,QAAQkB,KAAmC,YAA5BjB,EAAOD,QAAQa,SAC/BT,KAAKe,UAAUC,oBACfR,EAAmB,MAAMM,OAAOG,QAKhC,SAAUpB,EAAQD,EAASO,GAEjC,aAWA,SAASe,EAAQC,EAASC,GACxB,IAAIC,EAAKpB,KAET,KAAMA,gBAAgBiB,GACpB,MAAM,IAAII,YAAY,oDAGxB,GAAuB,mBAAZH,EACT,MAAM,IAAIG,YAAY,uDAGxB,IAAIC,EAAa,GACbC,EAAU,GAGdvB,KAAKwB,UAAW,EAChBxB,KAAKyB,UAAW,EAChBzB,KAAK0B,SAAU,EASf,IAAIC,EAAW,SAAUC,EAAWC,GAClCP,EAAWQ,KAAKF,GAChBL,EAAQO,KAAKD,IASf7B,KAAK+B,KAAO,SAAUH,EAAWC,GAC/B,OAAO,IAAIZ,EAAQ,SAAUe,EAASC,GACpC,IAAIC,EAAIN,EAAYO,EAAMP,EAAWI,EAASC,GAAUD,EACpDI,EAAIP,EAAYM,EAAMN,EAAWG,EAASC,GAAUA,EAExDN,EAASO,EAAGE,IACXhB,IAQL,IAAIiB,EAAW,SAAUC,GAgBvB,OAdAlB,EAAGI,UAAW,EACdJ,EAAGK,UAAW,EACdL,EAAGM,SAAU,EAEbJ,EAAWiB,QAAQ,SAAUC,GAC3BA,EAAGF,KAGLX,EAAW,SAAUC,EAAWC,GAC9BD,EAAUU,IAGZD,EAAWI,EAAU,aAEdrB,GAQLqB,EAAU,SAAUC,GAgBtB,OAdAtB,EAAGI,UAAW,EACdJ,EAAGK,UAAW,EACdL,EAAGM,SAAU,EAEbH,EAAQgB,QAAQ,SAAUC,GACxBA,EAAGE,KAGLf,EAAW,SAAUC,EAAWC,GAC9BA,EAAOa,IAGTL,EAAWI,EAAU,aAEdrB,GAOTpB,KAAK2C,OAAS,WAQZ,OAPIxB,EACFA,EAAOwB,SAGPF,EAAQ,IAAIG,GAGPxB,GAUTpB,KAAK6C,QAAU,SAAUC,GACvB,GAAI3B,EACFA,EAAO0B,QAAQC,OAEZ,CACH,IAAIC,EAAQC,WAAW,WACrBP,EAAQ,IAAIQ,EAAa,2BAA6BH,EAAQ,SAC7DA,GAEH1B,EAAG8B,OAAO,WACRC,aAAaJ,KAIjB,OAAO3B,GAITF,EAAQ,SAAUoB,GAChBD,EAASC,IACR,SAAUI,GACXD,EAAQC,KAYZ,SAASP,EAAMiB,EAAUpB,EAASC,GAChC,OAAO,SAAUK,GACf,IACE,IAAIe,EAAMD,EAASd,GACfe,GAA2B,mBAAbA,EAAItB,MAA+C,mBAAjBsB,EAAW,MAE7DA,EAAItB,KAAKC,EAASC,GAGlBD,EAAQqB,GAGZ,MAAOX,GACLT,EAAOS,KA6Eb,SAASE,EAAkBU,GACzBtD,KAAKsD,QAAUA,GAAW,oBAC1BtD,KAAKuD,OAAQ,IAAKC,OAASD,MAe7B,SAASN,EAAaK,GACpBtD,KAAKsD,QAAUA,GAAW,mBAC1BtD,KAAKuD,OAAQ,IAAKC,OAASD,MAtF7BtC,EAAQwC,UAAiB,MAAI,SAAU5B,GACrC,OAAO7B,KAAK+B,KAAK,KAAMF,IAWzBZ,EAAQwC,UAAUP,OAAS,SAAUV,GACnC,OAAOxC,KAAK+B,KAAKS,EAAIA,IASvBvB,EAAQyC,IAAM,SAAUC,GACtB,OAAO,IAAI1C,EAAQ,SAAUe,EAASC,GACpC,IAAI2B,EAAYD,EAAS3C,OACrB6C,EAAU,GAEVD,EACFD,EAASpB,QAAQ,SAAUuB,EAAGC,GAC5BD,EAAE/B,KAAK,SAAUO,GACfuB,EAAQE,GAAKzB,EAEI,KADjBsB,GAEE5B,EAAQ6B,IAET,SAAUnB,GACXkB,EAAY,EACZ3B,EAAOS,OAKXV,EAAQ6B,MASd5C,EAAQ+C,MAAQ,WACd,IAAIC,EAAW,GAOf,OALAA,EAASC,QAAU,IAAIjD,EAAQ,SAAUe,EAASC,GAChDgC,EAASjC,QAAUA,EACnBiC,EAAShC,OAASA,IAGbgC,IAaTrB,EAAkBa,UAAY,IAAID,OACNW,YAAcX,MAC1CZ,EAAkBa,UAAUW,KAAO,oBAEnCnD,EAAQ2B,kBAAoBA,GAa5BK,EAAaQ,UAAY,IAAID,OACNW,YAAcX,MACrCP,EAAaQ,UAAUW,KAAO,eAE9BnD,EAAQgC,aAAeA,EAGvBrD,EAAOD,QAAUsB,GAKX,SAAUrB,OAAQD,SAGxB,IAAIY,mBAAqB8D,KACrB,0HAKJzE,OAAOD,QAAUY,oBAKX,SAAUX,EAAQD,EAASO,GAEjC,IAAIoE,EAAcpE,EAAoB,GAQtCP,EAAQ4E,KAAO,SAAcC,EAAQC,GAGnC,OAAO,IAFIvE,EAAoB,GAExB,CAASsE,EAAQC,IAO1B9E,EAAQ+E,OAAS,SAAgBC,GAC/B,IAAID,EAASxE,EAAoB,GACjCwE,EAAOE,IAAID,IAObhF,EAAQsB,QAAUf,EAAoB,GAEtCP,EAAQa,SAAW8D,EAAY9D,SAC/Bb,EAAQe,aAAe4D,EAAY5D,aACnCf,EAAQkB,KAAOyD,EAAYzD,MAIrB,SAAUjB,EAAQD,EAASO,GAEjC,IAAIe,EAAUf,EAAoB,GAC9B2E,EAAgB3E,EAAoB,GACpCoE,EAAcpE,EAAoB,GAElC4E,EAAuB,IADF5E,EAAoB,IAQ7C,SAAS6E,EAAKP,EAAQC,GACE,iBAAXD,EACTxE,KAAKwE,OAASA,GAAU,MAGxBxE,KAAKwE,OAAS,KACdC,EAAUD,GAGZxE,KAAKgF,QAAU,GACfhF,KAAKiF,MAAQ,IAEbR,EAAUA,GAAW,IAGTS,YACVC,QAAQC,KACJ,uGAINpF,KAAKqF,SAAWZ,EAAQY,UAAY,GACpCrF,KAAKsF,SAAWb,EAAQa,UAAY,GACpCtF,KAAKuF,eAAkBd,EAAQc,gBAAkB,MACjDvF,KAAKkF,WAAaT,EAAQS,WAC1BlF,KAAKwF,WAAaf,EAAQe,YAAcf,EAAQS,YAAc,OAC9DlF,KAAKyF,aAAehB,EAAQgB,cAAgBC,EAAAA,EAGxCjB,GAAW,eAAgBA,GAuVjC,SAA4BkB,GAC1B,IAAKC,EAASD,KAAgBE,EAAUF,IAAeA,EAAa,EAClE,MAAM,IAAIG,UAAU,oDAxVpBC,CAAmBtB,EAAQkB,YAC3B3F,KAAK2F,WAAalB,EAAQkB,YAG1B3F,KAAK2F,WAAaK,KAAKC,KAAK3B,EAAYzD,MAAQ,GAAK,EAAG,GAGtD4D,GAAW,eAAgBA,IACH,QAAvBA,EAAQyB,WACTlG,KAAKkG,WAAalG,KAAK2F,YAwV7B,SAA4BO,GAC1B,IAAKN,EAASM,KAAgBL,EAAUK,IAAeA,EAAa,EAClE,MAAM,IAAIJ,UAAU,oDAxVlBK,CAAmB1B,EAAQyB,YAC3BlG,KAAKkG,WAAazB,EAAQyB,WAC1BlG,KAAK2F,WAAaK,KAAKC,IAAIjG,KAAKkG,WAAYlG,KAAK2F,aAEnD3F,KAAKoG,qBAGPpG,KAAKqG,WAAarG,KAAKsG,MAAMC,KAAKvG,MAGV,WAApBA,KAAKwF,YACPX,EAAc2B,sBAsVlB,SAASZ,EAASa,GAChB,MAAwB,iBAAVA,EAQhB,SAASZ,EAAUY,GACjB,OAAOT,KAAKU,MAAMD,IAAUA,EA5T9B1B,EAAKtB,UAAUkD,KAAO,SAAUC,EAAQC,GAEtC,GAAIA,IAAWC,MAAMC,QAAQF,GAC3B,MAAM,IAAIf,UAAU,uCAGtB,GAAsB,iBAAXc,EAAqB,CAC9B,IAAI3C,EAAWhD,EAAQ+C,QAEvB,GAAIhE,KAAKiF,MAAMjE,QAAUhB,KAAKyF,aAC5B,MAAM,IAAIjC,MAAM,qBAAuBxD,KAAKyF,aAAe,YAI7D,IAAIR,EAAQjF,KAAKiF,MACb+B,EAAO,CACTJ,OAASA,EACTC,OAASA,EACT5C,SAAUA,EACVpB,QAAS,MAEXoC,EAAMnD,KAAKkF,GAIX,IAAIC,EAAkBhD,EAASC,QAAQrB,QAgBvC,OAfAoB,EAASC,QAAQrB,QAAU,SAAkBC,GAC3C,OAA6B,IAAzBmC,EAAMiC,QAAQF,IAEhBA,EAAKnE,QAAUC,EACRmB,EAASC,SAIT+C,EAAgBE,KAAKlD,EAASC,QAASpB,IAKlD9C,KAAKsG,QAEErC,EAASC,QAEb,GAAsB,mBAAX0C,EAEd,OAAO5G,KAAK2G,KAAK,MAAO,CAACS,OAAOR,GAASC,IAGzC,MAAM,IAAIf,UAAU,qDAUxBf,EAAKtB,UAAU4D,MAAQ,WACrB,GAAuB,EAAnBC,UAAUtG,OACZ,MAAM,IAAIwC,MAAM,yBAGlB,IAAIe,EAAOvE,KACX,OAAOA,KAAK2G,KAAK,WACZ5E,KAAK,SAAU4C,GACd,IAAI0C,EAAQ,GAQZ,OANA1C,EAAQpC,QAAQ,SAAUqE,GACxBS,EAAMT,GAAU,WACd,OAAOrC,EAAKoC,KAAKC,EAAQE,MAAMrD,UAAU8D,MAAMJ,KAAKG,eAIjDD,KAwBftC,EAAKtB,UAAU6C,MAAQ,WACrB,GAAwB,EAApBtG,KAAKiF,MAAMjE,OAAY,CAIzB,IAAI0D,EAAS1E,KAAKwH,aAClB,GAAI9C,EAAQ,CAEV,IAAItD,EAAKpB,KACLgH,EAAOhH,KAAKiF,MAAMwC,QAGtB,GAAIT,EAAK/C,SAASC,QAAQxC,QAAS,CAEjC,IAAIwC,EAAUQ,EAAOiC,KAAKK,EAAKJ,OAAQI,EAAKH,OAAQG,EAAK/C,UACtDlC,KAAKX,EAAGiF,YACRqB,MAAM,WAEDhD,EAAOiD,aACTvG,EAAGwG,cAAclD,GAEjBtD,EAAGgF,qBAELhF,EAAGkF,UAIqB,iBAAjBU,EAAKnE,SACdqB,EAAQrB,QAAQmE,EAAKnE,cAIvBzB,EAAGkF,WAeXvB,EAAKtB,UAAU+D,WAAa,WAG1B,IADA,IAAIxC,EAAUhF,KAAKgF,QACVjB,EAAI,EAAGA,EAAIiB,EAAQhE,OAAQ+C,IAAK,CACvC,IAAIW,EAASM,EAAQjB,GACrB,IAAsB,IAAlBW,EAAOmD,OACT,OAAOnD,EAIX,OAAIM,EAAQhE,OAAShB,KAAK2F,YAExBjB,EAAS1E,KAAK8H,uBACd9C,EAAQlD,KAAK4C,GACNA,GAGF,MASTK,EAAKtB,UAAUmE,cAAgB,SAASlD,GACtCI,EAAqBiD,YAAYrD,EAAOsD,WAExCtD,EAAOuD,YACPjI,KAAKkI,sBAAsBxD,IAQ7BK,EAAKtB,UAAUyE,sBAAwB,SAASxD,GAE9C,IAAIyD,EAAQnI,KAAKgF,QAAQkC,QAAQxC,IAClB,IAAXyD,GACFnI,KAAKgF,QAAQoD,OAAOD,EAAO,IAc/BpD,EAAKtB,UAAUwE,UAAY,SAAUI,EAAOxF,GAE1C7C,KAAKiF,MAAM1C,QAAQ,SAAUyE,GAC3BA,EAAK/C,SAAShC,OAAO,IAAIuB,MAAM,sBAEjCxD,KAAKiF,MAAMjE,OAAS,EAEpB,IAGIsH,EAHI,SAAU5D,GAChB1E,KAAKkI,sBAAsBxD,IAER6B,KAAKvG,MAEtB2D,EAAW,GAOf,OANc3D,KAAKgF,QAAQuC,QACnBhF,QAAQ,SAAUmC,GACxB,IAAI6D,EAAc7D,EAAO8D,mBAAmBH,EAAOxF,GAChDd,KAAKuG,GACR3E,EAAS7B,KAAKyG,KAETtH,EAAQyC,IAAIC,IAQrBoB,EAAKtB,UAAUgF,MAAQ,SAAUJ,GAC/BlD,QAAQC,KAAK,6DACbpF,KAAKiI,UAAUI,IAOjBtD,EAAKtB,UAAUiF,MAAQ,WACrB,IAAIC,EAAe3I,KAAKgF,QAAQhE,OAC5B4H,EAAc5I,KAAKgF,QAAQ6D,OAAO,SAAUnE,GAC9C,OAAOA,EAAOmD,SACb7G,OAEH,MAAO,CACL2H,aAAeA,EACfC,YAAeA,EACfE,YAAeH,EAAeC,EAE9BG,aAAe/I,KAAKiF,MAAMjE,OAC1BgI,YAAeJ,IAQnB7D,EAAKtB,UAAU2C,kBAAoB,WACjC,GAAIpG,KAAKkG,WACP,IAAI,IAAInC,EAAI/D,KAAKgF,QAAQhE,OAAQ+C,EAAI/D,KAAKkG,WAAYnC,IACpD/D,KAAKgF,QAAQlD,KAAK9B,KAAK8H,yBAU7B/C,EAAKtB,UAAUqE,qBAAuB,WACpC,OAAO,IAAIjD,EAAc7E,KAAKwE,OAAQ,CACpCa,SAAUrF,KAAKqF,SACfC,SAAUtF,KAAKsF,SACf0C,UAAWlD,EAAqBmE,wBAAwBjJ,KAAKuF,gBAC7DC,WAAYxF,KAAKwF,cA4CrB5F,EAAOD,QAAUoF,GAKX,SAAUnF,EAAQD,EAASO,GAEjC,aAGA,IAAIe,EAAUf,EAAoB,GAC9BoE,EAAcpE,EAAoB,GAClCK,EAAqBL,EAAoB,GAE7C,SAASsG,IACP,IAAI0C,EAAgBC,IACpB,IAAKD,EACH,MAAM,IAAI1F,MAAM,+EAGlB,OAAO0F,EAIT,SAASE,IAEP,GAAsB,mBAAXC,SAA4C,iBAAXA,QAA+D,mBAAjCA,OAAO5F,UAAUU,aACzF,MAAM,IAAIX,MAAM,yCAIpB,SAAS2F,IACP,IACE,OAAO5I,EAAmB,kBAC1B,MAAMmC,GACN,GAAqB,iBAAVA,GAAgC,OAAVA,GAAiC,qBAAfA,EAAM4G,KAEvD,OAAO,KAEP,MAAM5G,GAmDZ,SAAS6G,EAAmB/E,EAAQ6E,GAElC,IAAI3E,EAAS,IAAI2E,EAAO7E,GAYxB,OAVAE,EAAO8E,iBAAkB,EAEzB9E,EAAO+E,GAAK,SAAUC,EAAOtG,GAC3BpD,KAAK2J,iBAAiBD,EAAO,SAAUpG,GACrCF,EAASE,EAAQsG,SAGrBlF,EAAOmF,KAAO,SAAUvG,GACtBtD,KAAK8J,YAAYxG,IAEZoB,EAGT,SAASqF,EAAwBvF,EAAQ0E,GACvC,IAAIxE,EAAS,IAAIwE,EAAcG,OAAO7E,EAAQ,CAC5CwF,QAAQ,EACRC,QAAQ,IAgBV,OAdAvF,EAAOwF,gBAAiB,EAExBxF,EAAOmF,KAAO,SAASvG,GACrBtD,KAAK8J,YAAYxG,IAGnBoB,EAAOyF,KAAO,WACZnK,KAAKiI,aAGPvD,EAAO0F,WAAa,WAClBpK,KAAKiI,aAGAvD,EAGT,SAAS2F,EAAmB7F,EAAQC,EAAS6F,GAE3C,IAAI5F,EAAS4F,EAAcC,KACzB/F,EACAC,EAAQY,SACRZ,EAAQa,UAIV,OADAZ,EAAO8F,gBAAiB,EACjB9F,EAIT,SAAS+F,EAAmBC,GAC1BA,EAAOA,GAAQ,GAEf,IAAIC,EAAkBlK,QAAQmK,SAASC,KAAK,KACxCC,GAA4D,IAA1CH,EAAgBzD,QAAQ,aAC1C6D,GAAuD,IAA5CJ,EAAgBzD,QAAQ,eAEnC0D,EAAW,GAef,OAdIE,IACFF,EAAS9I,KAAK,aAAe4I,EAAK1C,WAE9B+C,GACFH,EAAS9I,KAAK,gBAIlBrB,QAAQmK,SAASrI,QAAQ,SAASyI,IACW,EAAvCA,EAAI9D,QAAQ,yBACd0D,EAAS9I,KAAKkJ,KAIXC,OAAOC,OAAO,GAAIR,EAAM,CAC7BrF,SAAUqF,EAAKrF,SACfC,SAAU2F,OAAOC,OAAO,GAAIR,EAAKpF,SAAU,CACzCsF,UAAWF,EAAKpF,UAAYoF,EAAKpF,SAASsF,UAAY,IACrDO,OAAOP,OA6Bd,SAAS/F,EAAcL,EAAQ4G,GAC7B,IAAIhK,EAAKpB,KACLyE,EAAU2G,GAAY,GA2C1B,SAASC,EAAQ3I,GAOf,IAAK,IAAI4I,KANTlK,EAAGuG,YAAa,EACZvG,EAAGmK,aAAenK,EAAGoK,oBACvBpK,EAAGoK,mBAAmBpK,GAExBA,EAAGmK,aAAc,EAEFnK,EAAGqK,gBACUC,IAAtBtK,EAAGqK,WAAWH,IAChBlK,EAAGqK,WAAWH,GAAIrH,SAAShC,OAAOS,GAGtCtB,EAAGqK,WAAaR,OAAOU,OAAO,MArDhC3L,KAAKwE,OAASA,GA5JhB,WACE,GAA6B,YAAzBF,EAAY9D,SAed,OAAOoL,UAAY,aAbnB,GAAoB,oBAATC,KACT,MAAM,IAAIrI,MAAM,qCAElB,IAAKsI,OAAOC,KAA6C,mBAA/BD,OAAOC,IAAIC,gBACnC,MAAM,IAAIxI,MAAM,oDAIlB,IAAIyI,EAAO,IAAIJ,KAAK,CAAC3L,EAAoB,IAAK,CAACgM,KAAM,oBACrD,OAAOJ,OAAOC,IAAIC,gBAAgBC,GAgJZE,GACxBnM,KAAK0E,OAzIP,SAAqBF,EAAQC,GAC3B,GAA2B,QAAvBA,EAAQe,WAEV,OADA4D,IACOG,EAAmB/E,EAAQ6E,QAC7B,GAA2B,WAAvB5E,EAAQe,WAEjB,OAAOuE,EAAwBvF,EAD/B0E,EAAgB1C,KAEX,GAA2B,YAAvB/B,EAAQe,YAA6Bf,EAAQe,WAEjD,CACL,GAA6B,YAAzBlB,EAAY9D,SAEd,OADA4I,IACOG,EAAmB/E,EAAQ6E,QAGlC,IAAIH,EAAgBC,IACpB,OAAID,EACKa,EAAwBvF,EAAQ0E,GAEhCmB,EAAmB7F,EAAQiG,EAAmBhG,GAAUlE,EAAmB,kBAXtF,OAAO8J,EAAmB7F,EAAQiG,EAAmBhG,GAAUlE,EAAmB,kBAiItE6L,CAAYpM,KAAKwE,OAAQC,GACvCzE,KAAKgI,UAAYvD,EAAQuD,UAGpBxD,IACHxE,KAAK0E,OAAO2H,OAAQ,GAItBrM,KAAKsM,aAAe,GACpBtM,KAAK0E,OAAO+E,GAAG,UAAW,SAAU8C,GAClC,GAAwB,iBAAbA,GAAsC,UAAbA,EAClCnL,EAAGsD,OAAO2H,OAAQ,EA8CpBjL,EAAGkL,aAAa/J,QAAQnB,EAAGsD,OAAOmF,KAAKtD,KAAKnF,EAAGsD,SAC/CtD,EAAGkL,aAAe,OA7CX,CAEL,IAAIhB,EAAKiB,EAASjB,GACdtE,EAAO5F,EAAGqK,WAAWH,QACZI,IAAT1E,WAEK5F,EAAGqK,WAAWH,IAGE,IAAnBlK,EAAGmK,aAELnK,EAAG6G,YAIDsE,EAAS7J,MACXsE,EAAK/C,SAAShC,OAtDxB,SAAwBuK,GAItB,IAHA,IAAIC,EAAO,IAAIjJ,MAAM,IACjBkJ,EAAQzB,OAAO0B,KAAKH,GAEfzI,EAAI,EAAGA,EAAI2I,EAAM1L,OAAQ+C,IAChC0I,EAAKC,EAAM3I,IAAMyI,EAAIE,EAAM3I,IAG7B,OAAO0I,EA8CsBG,CAAcL,EAAS7J,QAG5CsE,EAAK/C,SAASjC,QAAQuK,EAASjK,YA6BvC,IAAIoC,EAAS1E,KAAK0E,OAElB1E,KAAK0E,OAAO+E,GAAG,QAAS4B,GACxBrL,KAAK0E,OAAO+E,GAAG,OAAQ,SAAUoD,EAAUC,GACzC,IAAIxJ,EAAU,8CAEdA,GAAW,kBAAoBuJ,EAAW,MAC1CvJ,GAAW,oBAAsBwJ,EAAa,MAE9CxJ,GAAW,2BAA8BlC,EAAGoD,OAAS,MACrDlB,GAAW,mBAAsBoB,EAAOqI,UAAY,MACpDzJ,GAAW,mBAAqBoB,EAAOsI,UAAY,MAEnD1J,GAAW,gBAAkBoB,EAAOsF,OAAS,MAC7C1G,GAAW,gBAAkBoB,EAAOuF,OAAS,MAE7CoB,EAAQ,IAAI7H,MAAMF,MAGpBtD,KAAKyL,WAAaR,OAAOU,OAAO,MAEhC3L,KAAKuL,aAAc,EACnBvL,KAAK2H,YAAa,EAClB3H,KAAKwL,mBAAqB,KAC1BxL,KAAKiN,OAAS,EAOhBpI,EAAcpB,UAAUkB,QAAU,WAChC,OAAO3E,KAAK2G,KAAK,YAUnB9B,EAAcpB,UAAUkD,KAAO,SAASC,EAAQC,EAAQ5C,GAEpDA,EADGA,GACQhD,EAAQ+C,QAIrB,IAAIsH,IAAOtL,KAAKiN,OAGhBjN,KAAKyL,WAAWH,GAAM,CACpBA,GAAIA,EACJrH,SAAUA,GAIZ,IAAIiJ,EAAU,CACZ5B,GAAIA,EACJ1E,OAAQA,EACRC,OAAQA,GAGN7G,KAAK2H,WACP1D,EAAShC,OAAO,IAAIuB,MAAM,yBACjBxD,KAAK0E,OAAO2H,MAErBrM,KAAK0E,OAAOmF,KAAKqD,GAEjBlN,KAAKsM,aAAaxK,KAAKoL,GAIzB,IAAI9L,EAAKpB,KAeT,OAdAiE,EAASC,QACNwD,MAAM,SAAUhF,GACf,KAAIA,aAAiBzB,EAAQ2B,mBAAqBF,aAAiBzB,EAAQgC,cAQzE,MAAMP,SALCtB,EAAGqK,WAAWH,GAGrBlK,EAAG6G,WAAU,KAMZhE,EAASC,SAOlBW,EAAcpB,UAAUoE,KAAO,WAC7B,OAA6C,EAAtCoD,OAAO0B,KAAK3M,KAAKyL,YAAYzK,QAWtC6D,EAAcpB,UAAUwE,UAAY,SAAUI,EAAOjF,GACnD,GAAIiF,EAAO,CAET,IAAK,IAAIiD,KAAMtL,KAAKyL,gBACUC,IAAxB1L,KAAKyL,WAAWH,IAClBtL,KAAKyL,WAAWH,GAAIrH,SAAShC,OAAO,IAAIuB,MAAM,sBAGlDxD,KAAKyL,WAAaR,OAAOU,OAAO,MAMlC,GAHwB,mBAAbvI,IACTpD,KAAKwL,mBAAqBpI,GAEvBpD,KAAK6H,OAsBR7H,KAAKuL,aAAc,MAtBH,CAEhB,GAAIvL,KAAK0E,OAAQ,CACf,GAAgC,mBAArB1E,KAAK0E,OAAOyF,KACrBnK,KAAK0E,OAAOyF,WAET,CAAA,GAAqC,mBAA1BnK,KAAK0E,OAAOuD,UAI1B,MAAM,IAAIzE,MAAM,8BAHhBxD,KAAK0E,OAAOuD,YAKdjI,KAAK0E,OAAS,KAEhB1E,KAAKuL,aAAc,EACnBvL,KAAK2H,YAAa,EACd3H,KAAKwL,oBACPxL,KAAKwL,mBAAmBxL,QAmB9B6E,EAAcpB,UAAU+E,mBAAqB,SAAUH,EAAOxF,GAC5D,IAAIoB,EAAWhD,EAAQ+C,QAOvB,OANInB,IACFoB,EAASC,QAAQrB,QAAUA,GAE7B7C,KAAKiI,UAAUI,EAAO,SAAS3D,GAC7BT,EAASjC,QAAQ0C,KAEZT,EAASC,SAGlBtE,EAAOD,QAAUkF,EACjBjF,EAAOD,QAAQwN,yBAA2BhE,EAC1CvJ,EAAOD,QAAQyN,oBAAsB/C,EACrCzK,EAAOD,QAAQ0N,oBAAsB9D,EACrC3J,EAAOD,QAAQ2N,yBAA2BvD,EAC1CnK,EAAOD,QAAQ6G,oBAAsBA,GAK/B,SAAU5G,EAAQD,GAOxBC,EAAOD,QAAU,gzFAKX,SAAUC,EAAQD,EAASO,GAEjC,aAKA,SAASqN,IACPvN,KAAKwN,MAAQvC,OAAOU,OAAO,MAC3B3L,KAAKgB,OAAS,GAHhBpB,EAAOD,QAAU4N,GAME9J,UAAUwF,wBAA0B,SAASwE,GAC9D,MAAgC,IAAzBzN,KAAKwN,MAAMC,IAChBA,IAGF,GAZc,OAYVA,EACF,MAAM,IAAIjK,MAAM,wCAA0CiK,EAAW,YAKvE,OAFAzN,KAAKwN,MAAMC,IAAY,EACvBzN,KAAKgB,SACEyM,GAGTF,EAAmB9J,UAAUsE,YAAc,SAAS2F,UAC3C1N,KAAKwN,MAAME,GAClB1N,KAAKgB,WAOD,SAAUpB,OAAQD,QAASO,qBAQjC,IAAIK,mBAAqB8D,KACrB,0HAOAK,OAAS,GACb,GAAoB,oBAAT3E,MAA+C,mBAAhB+J,aAA0D,mBAArBH,iBAE7EjF,OAAO+E,GAAK,SAAUC,EAAOtG,GAC3BuG,iBAAiBD,EAAO,SAAUpG,GAChCF,EAASE,EAAQsG,SAGrBlF,OAAOmF,KAAO,SAAUvG,GACtBwG,YAAYxG,QAGX,CAAA,GAAuB,oBAAZ7C,QA8Bd,MAAM,IAAI+C,MAAM,uCA3BhB,IAAI0F,cACJ,IACEA,cAAgB3I,mBAAmB,kBACnC,MAAMmC,GACN,GAAqB,iBAAVA,GAAgC,OAAVA,GAAgC,oBAAdA,EAAM4G,KAGvD,MAAM5G,EAIV,GAAIwG,eAE2B,OAA7BA,cAAcyE,WAAqB,CACnC,IAAIA,WAAczE,cAAcyE,WAChCjJ,OAAOmF,KAAO8D,WAAW7D,YAAYvD,KAAKoH,YAC1CjJ,OAAO+E,GAAKkE,WAAWlE,GAAGlD,KAAKoH,iBAE/BjJ,OAAO+E,GAAKhJ,QAAQgJ,GAAGlD,KAAK9F,SAC5BiE,OAAOmF,KAAOpJ,QAAQoJ,KAAKtD,KAAK9F,SAEhCiE,OAAO+E,GAAG,aAAc,WACtBhJ,QAAQmN,KAAK,KAQnB,SAASC,aAAanL,GACpB,OAAOuI,OAAO6C,oBAAoBpL,GAAOqL,OAAO,SAASC,EAAS5J,GAChE,OAAO6G,OAAOgD,eAAeD,EAAS5J,EAAM,CAC/CqC,MAAO/D,EAAM0B,GACb8J,YAAY,KAER,IASL,SAASC,UAAU1H,GACjB,OAAOA,GAAgC,mBAAfA,EAAM1E,MAAgD,mBAAhB0E,EAAMiB,MAItEhD,OAAOC,QAAU,GAQjBD,OAAOC,QAAQyJ,IAAM,SAASA,IAAI5L,GAAI6L,MACpC,IAAIjM,EAAIiC,KAAK,IAAM7B,GAAK,KACxB,OAAOJ,EAAEkM,MAAMlM,EAAGiM,OAOpB3J,OAAOC,QAAQA,QAAU,WACvB,OAAOsG,OAAO0B,KAAKjI,OAAOC,UAG5BD,OAAO+E,GAAG,UAAW,SAAUyD,GAC7B,IACE,IAAItG,EAASlC,OAAOC,QAAQuI,EAAQtG,QAEpC,IAAIA,EAgCF,MAAM,IAAIpD,MAAM,mBAAqB0J,EAAQtG,OAAS,KA9BtD,IAAItE,EAASsE,EAAO0H,MAAM1H,EAAQsG,EAAQrG,QAEtCsH,UAAU7L,GAEZA,EACKP,KAAK,SAAUO,GACdoC,OAAOmF,KAAK,CACVyB,GAAI4B,EAAQ5B,GACZhJ,OAAQA,EACRI,MAAO,SAGVgF,MAAM,SAAU6G,GACf7J,OAAOmF,KAAK,CACVyB,GAAI4B,EAAQ5B,GACZhJ,OAAQ,KACRI,MAAOmL,aAAaU,OAM5B7J,OAAOmF,KAAK,CACVyB,GAAI4B,EAAQ5B,GACZhJ,OAAQA,EACRI,MAAO,OAQf,MAAO6L,GACL7J,OAAOmF,KAAK,CACVyB,GAAI4B,EAAQ5B,GACZhJ,OAAQ,KACRI,MAAOmL,aAAaU,QAS1B7J,OAAO8J,SAAW,SAAU7J,GAE1B,GAAIA,EACF,IAAK,IAAIP,KAAQO,EACXA,EAAQ8J,eAAerK,KACzBM,OAAOC,QAAQP,GAAQO,EAAQP,IAKrCM,OAAOmF,KAAK,UAKZlK,QAAQiF,IAAMF,OAAO8J,WA7/CTE,EAAmB,GA4BvBxO,EAAoByO,EAAI1O,EAGxBC,EAAoB0O,EAAIF,EAGxBxO,EAAoB2O,EAAI,SAASlP,EAASyE,EAAM0K,GAC3C5O,EAAoB6O,EAAEpP,EAASyE,IAClC6G,OAAOgD,eAAetO,EAASyE,EAAM,CAAE8J,YAAY,EAAMc,IAAKF,KAKhE5O,EAAoB+O,EAAI,SAAStP,GACX,oBAAXuP,QAA0BA,OAAOC,aAC1ClE,OAAOgD,eAAetO,EAASuP,OAAOC,YAAa,CAAE1I,MAAO,WAE7DwE,OAAOgD,eAAetO,EAAS,aAAc,CAAE8G,OAAO,KAQvDvG,EAAoBkP,EAAI,SAAS3I,EAAO4I,GAEvC,GADU,EAAPA,IAAU5I,EAAQvG,EAAoBuG,IAC/B,EAAP4I,EAAU,OAAO5I,EACpB,GAAW,EAAP4I,GAA8B,iBAAV5I,GAAsBA,GAASA,EAAM6I,WAAY,OAAO7I,EAChF,IAAI8I,EAAKtE,OAAOU,OAAO,MAGvB,GAFAzL,EAAoB+O,EAAEM,GACtBtE,OAAOgD,eAAesB,EAAI,UAAW,CAAErB,YAAY,EAAMzH,MAAOA,IACtD,EAAP4I,GAA4B,iBAAT5I,EAAmB,IAAI,IAAI+I,KAAO/I,EAAOvG,EAAoB2O,EAAEU,EAAIC,EAAK,SAASA,GAAO,OAAO/I,EAAM+I,IAAQjJ,KAAK,KAAMiJ,IAC9I,OAAOD,GAIRrP,EAAoBuP,EAAI,SAAS7P,GAChC,IAAIkP,EAASlP,GAAUA,EAAO0P,WAC7B,WAAwB,OAAO1P,EAAgB,SAC/C,WAA8B,OAAOA,GAEtC,OADAM,EAAoB2O,EAAEC,EAAQ,IAAKA,GAC5BA,GAIR5O,EAAoB6O,EAAI,SAASW,EAAQC,GAAY,OAAO1E,OAAOxH,UAAUgL,eAAetH,KAAKuI,EAAQC,IAGzGzP,EAAoB4D,EAAI,GAIjB5D,EAAoBA,EAAoBgC,EAAI,GA9EnD,SAAShC,EAAoB0P,GAG5B,GAAGlB,EAAiBkB,GACnB,OAAOlB,EAAiBkB,GAAUjQ,QAGnC,IAAIC,EAAS8O,EAAiBkB,GAAY,CACzC7L,EAAG6L,EACHC,GAAG,EACHlQ,QAAS,IAUV,OANAM,EAAQ2P,GAAUzI,KAAKvH,EAAOD,QAASC,EAAQA,EAAOD,QAASO,GAG/DN,EAAOiQ,GAAI,EAGJjQ,EAAOD,QAzBT,IAAUM,EAEZyO"}
+{"version":3,"sources":["0"],"names":["root","factory","exports","module","define","amd","self","this","modules","__webpack_require__","isNode","nodeProcess","versions","node","requireFoolWebpack","platform","process","worker_threads","err","tryRequireFoolWebpack","isMainThread","connected","Window","cpus","navigator","hardwareConcurrency","length","Promise","handler","parent","me","SyntaxError","_onSuccess","_onFail","resolved","rejected","pending","_process","onSuccess","onFail","push","then","resolve","reject","s","_then","f","_resolve","result","forEach","fn","_reject","error","cancel","CancellationError","timeout","delay","timer","setTimeout","TimeoutError","always","clearTimeout","callback","res","message","stack","Error","prototype","all","promises","remaining","results","p","i","defer","resolver","promise","constructor","name","eval","environment","pool","script","options","worker","methods","add","WorkerHandler","DEBUG_PORT_ALLOCATOR","Pool","workers","tasks","nodeWorker","console","warn","forkArgs","forkOpts","debugPortStart","workerType","maxQueueSize","Infinity","maxWorkers","isNumber","isInteger","TypeError","validateMaxWorkers","Math","max","minWorkers","validateMinWorkers","_ensureMinWorkers","_boundNext","_next","bind","ensureWorkerThreads","value","round","exec","method","params","Array","isArray","task","originalTimeout","indexOf","call","String","proxy","arguments","slice","_getWorker","shift","catch","terminated","_removeWorker","busy","_createWorkerHandler","releasePort","debugPort","terminate","_removeWorkerFromList","index","splice","force","removeWorker","termPromise","terminateAndNotify","clear","stats","totalWorkers","busyWorkers","filter","idleWorkers","pendingTasks","activeTasks","nextAvailableStartingAt","WorkerThreads","tryRequireWorkerThreads","ensureWebWorker","Worker","code","setupBrowserWorker","isBrowserWorker","on","event","addEventListener","data","send","postMessage","setupWorkerThreadWorker","stdout","stderr","isWorkerThread","kill","disconnect","setupProcessWorker","child_process","fork","isChildProcess","resolveForkOptions","opts","processExecArgv","execArgv","join","inspectorActive","debugBrk","arg","Object","assign","concat","_options","onError","id","terminating","terminationHandler","processing","undefined","create","__dirname","Blob","window","URL","createObjectURL","blob","type","getDefaultWorker","setupWorker","ready","requestQueue","response","obj","temp","props","keys","objectToError","exitCode","signalCode","spawnargs","spawnfile","lastId","request","_tryRequireWorkerThreads","_setupProcessWorker","_setupBrowserWorker","_setupWorkerThreadWorker","DebugPortAllocator","ports","starting","port","parentPort","exit","convertError","getOwnPropertyNames","reduce","product","defineProperty","enumerable","isPromise","run","args","apply","register","hasOwnProperty","installedModules","m","c","d","getter","o","get","r","Symbol","toStringTag","t","mode","__esModule","ns","key","n","object","property","moduleId","l"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;CAyBA,SAA2CA,EAAMC,GAC1B,iBAAZC,SAA0C,iBAAXC,OACxCA,OAAOD,QAAUD,IACQ,mBAAXG,QAAyBA,OAAOC,IAC9CD,OAAO,aAAc,GAAIH,GACC,iBAAZC,QACdA,QAAoB,WAAID,IAExBD,EAAiB,WAAIC,IARvB,CASoB,oBAATK,KAAuBA,KAAOC,KAAO,WAChD,OAA0BC,EAsFhB,CAEJ,SAAUL,EAAQD,EAASO,GAKpB,SAATC,EAAmBC,GACrB,YACyB,IAAhBA,GACiB,MAAxBA,EAAYC,UACiB,MAA7BD,EAAYC,SAASC,KAPzB,IAAIC,EAAqBL,EAAoB,GAU7CN,EAAOD,QAAQQ,OAASA,EAGxBP,EAAOD,QAAQa,SAA8B,oBAAZC,SAA2BN,EAAOM,SAC/D,OACA,UAIJ,IAAIC,EAUJ,SAAgCd,GAC9B,IACE,OAAOW,EAAmBX,GAC1B,MAAMe,GACN,OAAO,MAdUC,CAAsB,kBAC3ChB,EAAOD,QAAQkB,aAA2C,SAA5BjB,EAAOD,QAAQa,WACtCE,GAAkBA,EAAeG,gBAAkBJ,QAAQK,UAC5C,oBAAXC,OAGXnB,EAAOD,QAAQqB,KAAmC,YAA5BpB,EAAOD,QAAQa,SACjCT,KAAKkB,UAAUC,oBACfX,EAAmB,MAAMS,OAAOG,QAa9B,SAAUvB,EAAQD,EAASO,GAEjC,aAWA,SAASkB,EAAQC,EAASC,GACxB,IAAIC,EAAKvB,KAET,KAAMA,gBAAgBoB,GACpB,MAAM,IAAII,YAAY,oDAGxB,GAAuB,mBAAZH,EACT,MAAM,IAAIG,YAAY,uDAGxB,IAAIC,EAAa,GACbC,EAAU,GAGd1B,KAAK2B,UAAW,EAChB3B,KAAK4B,UAAW,EAChB5B,KAAK6B,SAAU,EASf,IAAIC,EAAW,SAAUC,EAAWC,GAClCP,EAAWQ,KAAKF,GAChBL,EAAQO,KAAKD,IASfhC,KAAKkC,KAAO,SAAUH,EAAWC,GAC/B,OAAO,IAAIZ,EAAQ,SAAUe,EAASC,GACpC,IAAIC,EAAIN,EAAYO,EAAMP,EAAWI,EAASC,GAAUD,EACpDI,EAAIP,EAAYM,EAAMN,EAAWG,EAASC,GAAUA,EAExDN,EAASO,EAAGE,IACXhB,IAQL,IAAIiB,EAAW,SAAUC,GAgBvB,OAdAlB,EAAGI,UAAW,EACdJ,EAAGK,UAAW,EACdL,EAAGM,SAAU,EAEbJ,EAAWiB,QAAQ,SAAUC,GAC3BA,EAAGF,KAGLX,EAAW,SAAUC,EAAWC,GAC9BD,EAAUU,IAGZD,EAAWI,EAAU,aAEdrB,GAQLqB,EAAU,SAAUC,GAgBtB,OAdAtB,EAAGI,UAAW,EACdJ,EAAGK,UAAW,EACdL,EAAGM,SAAU,EAEbH,EAAQgB,QAAQ,SAAUC,GACxBA,EAAGE,KAGLf,EAAW,SAAUC,EAAWC,GAC9BA,EAAOa,IAGTL,EAAWI,EAAU,aAEdrB,GAOTvB,KAAK8C,OAAS,WAQZ,OAPIxB,EACFA,EAAOwB,SAGPF,EAAQ,IAAIG,GAGPxB,GAUTvB,KAAKgD,QAAU,SAAUC,GACvB,GAAI3B,EACFA,EAAO0B,QAAQC,OAEZ,CACH,IAAIC,EAAQC,WAAW,WACrBP,EAAQ,IAAIQ,EAAa,2BAA6BH,EAAQ,SAC7DA,GAEH1B,EAAG8B,OAAO,WACRC,aAAaJ,KAIjB,OAAO3B,GAITF,EAAQ,SAAUoB,GAChBD,EAASC,IACR,SAAUI,GACXD,EAAQC,KAYZ,SAASP,EAAMiB,EAAUpB,EAASC,GAChC,OAAO,SAAUK,GACf,IACE,IAAIe,EAAMD,EAASd,GACfe,GAA2B,mBAAbA,EAAItB,MAA+C,mBAAjBsB,EAAW,MAE7DA,EAAItB,KAAKC,EAASC,GAGlBD,EAAQqB,GAGZ,MAAOX,GACLT,EAAOS,KA6Eb,SAASE,EAAkBU,GACzBzD,KAAKyD,QAAUA,GAAW,oBAC1BzD,KAAK0D,OAAQ,IAAKC,OAASD,MAe7B,SAASN,EAAaK,GACpBzD,KAAKyD,QAAUA,GAAW,mBAC1BzD,KAAK0D,OAAQ,IAAKC,OAASD,MAtF7BtC,EAAQwC,UAAiB,MAAI,SAAU5B,GACrC,OAAOhC,KAAKkC,KAAK,KAAMF,IAWzBZ,EAAQwC,UAAUP,OAAS,SAAUV,GACnC,OAAO3C,KAAKkC,KAAKS,EAAIA,IASvBvB,EAAQyC,IAAM,SAAUC,GACtB,OAAO,IAAI1C,EAAQ,SAAUe,EAASC,GACpC,IAAI2B,EAAYD,EAAS3C,OACrB6C,EAAU,GAEVD,EACFD,EAASpB,QAAQ,SAAUuB,EAAGC,GAC5BD,EAAE/B,KAAK,SAAUO,GACfuB,EAAQE,GAAKzB,EAEI,KADjBsB,GAEE5B,EAAQ6B,IAET,SAAUnB,GACXkB,EAAY,EACZ3B,EAAOS,OAKXV,EAAQ6B,MASd5C,EAAQ+C,MAAQ,WACd,IAAIC,EAAW,GAOf,OALAA,EAASC,QAAU,IAAIjD,EAAQ,SAAUe,EAASC,GAChDgC,EAASjC,QAAUA,EACnBiC,EAAShC,OAASA,IAGbgC,IAaTrB,EAAkBa,UAAY,IAAID,OACNW,YAAcX,MAC1CZ,EAAkBa,UAAUW,KAAO,oBAEnCnD,EAAQ2B,kBAAoBA,GAa5BK,EAAaQ,UAAY,IAAID,OACNW,YAAcX,MACrCP,EAAaQ,UAAUW,KAAO,eAE9BnD,EAAQgC,aAAeA,EAGvBxD,EAAOD,QAAUyB,GAKX,SAAUxB,OAAQD,SAGxB,IAAIY,mBAAqBiE,KACrB,0HAKJ5E,OAAOD,QAAUY,oBAKX,SAAUX,EAAQD,EAASO,GAEjC,IAAIuE,EAAcvE,EAAoB,GAQtCP,EAAQ+E,KAAO,SAAcC,EAAQC,GAGnC,OAAO,IAFI1E,EAAoB,GAExB,CAASyE,EAAQC,IAO1BjF,EAAQkF,OAAS,SAAgBC,GAC/B,IAAID,EAAS3E,EAAoB,GACjC2E,EAAOE,IAAID,IAObnF,EAAQyB,QAAUlB,EAAoB,GAEtCP,EAAQa,SAAWiE,EAAYjE,SAC/Bb,EAAQkB,aAAe4D,EAAY5D,aACnClB,EAAQqB,KAAOyD,EAAYzD,MAIrB,SAAUpB,EAAQD,EAASO,GAEjC,IAAIkB,EAAUlB,EAAoB,GAC9B8E,EAAgB9E,EAAoB,GACpCuE,EAAcvE,EAAoB,GAElC+E,EAAuB,IADF/E,EAAoB,IAQ7C,SAASgF,EAAKP,EAAQC,GACE,iBAAXD,EACT3E,KAAK2E,OAASA,GAAU,MAGxB3E,KAAK2E,OAAS,KACdC,EAAUD,GAGZ3E,KAAKmF,QAAU,GACfnF,KAAKoF,MAAQ,IAEbR,EAAUA,GAAW,IAGTS,YACVC,QAAQC,KACJ,uGAINvF,KAAKwF,SAAWZ,EAAQY,UAAY,GACpCxF,KAAKyF,SAAWb,EAAQa,UAAY,GACpCzF,KAAK0F,eAAkBd,EAAQc,gBAAkB,MACjD1F,KAAKqF,WAAaT,EAAQS,WAC1BrF,KAAK2F,WAAaf,EAAQe,YAAcf,EAAQS,YAAc,OAC9DrF,KAAK4F,aAAehB,EAAQgB,cAAgBC,EAAAA,EAGxCjB,GAAW,eAAgBA,GAuVjC,SAA4BkB,GAC1B,IAAKC,EAASD,KAAgBE,EAAUF,IAAeA,EAAa,EAClE,MAAM,IAAIG,UAAU,oDAxVpBC,CAAmBtB,EAAQkB,YAC3B9F,KAAK8F,WAAalB,EAAQkB,YAG1B9F,KAAK8F,WAAaK,KAAKC,KAAK3B,EAAYzD,MAAQ,GAAK,EAAG,GAGtD4D,GAAW,eAAgBA,IACH,QAAvBA,EAAQyB,WACTrG,KAAKqG,WAAarG,KAAK8F,YAwV7B,SAA4BO,GAC1B,IAAKN,EAASM,KAAgBL,EAAUK,IAAeA,EAAa,EAClE,MAAM,IAAIJ,UAAU,oDAxVlBK,CAAmB1B,EAAQyB,YAC3BrG,KAAKqG,WAAazB,EAAQyB,WAC1BrG,KAAK8F,WAAaK,KAAKC,IAAIpG,KAAKqG,WAAYrG,KAAK8F,aAEnD9F,KAAKuG,qBAGPvG,KAAKwG,WAAaxG,KAAKyG,MAAMC,KAAK1G,MAGV,WAApBA,KAAK2F,YACPX,EAAc2B,sBAsVlB,SAASZ,EAASa,GAChB,MAAwB,iBAAVA,EAQhB,SAASZ,EAAUY,GACjB,OAAOT,KAAKU,MAAMD,IAAUA,EA5T9B1B,EAAKtB,UAAUkD,KAAO,SAAUC,EAAQC,GAEtC,GAAIA,IAAWC,MAAMC,QAAQF,GAC3B,MAAM,IAAIf,UAAU,uCAGtB,GAAsB,iBAAXc,EAAqB,CAC9B,IAAI3C,EAAWhD,EAAQ+C,QAEvB,GAAInE,KAAKoF,MAAMjE,QAAUnB,KAAK4F,aAC5B,MAAM,IAAIjC,MAAM,qBAAuB3D,KAAK4F,aAAe,YAI7D,IAAIR,EAAQpF,KAAKoF,MACb+B,EAAO,CACTJ,OAASA,EACTC,OAASA,EACT5C,SAAUA,EACVpB,QAAS,MAEXoC,EAAMnD,KAAKkF,GAIX,IAAIC,EAAkBhD,EAASC,QAAQrB,QAgBvC,OAfAoB,EAASC,QAAQrB,QAAU,SAAkBC,GAC3C,OAA6B,IAAzBmC,EAAMiC,QAAQF,IAEhBA,EAAKnE,QAAUC,EACRmB,EAASC,SAIT+C,EAAgBE,KAAKlD,EAASC,QAASpB,IAKlDjD,KAAKyG,QAEErC,EAASC,QAEb,GAAsB,mBAAX0C,EAEd,OAAO/G,KAAK8G,KAAK,MAAO,CAACS,OAAOR,GAASC,IAGzC,MAAM,IAAIf,UAAU,qDAUxBf,EAAKtB,UAAU4D,MAAQ,WACrB,GAAuB,EAAnBC,UAAUtG,OACZ,MAAM,IAAIwC,MAAM,yBAGlB,IAAIe,EAAO1E,KACX,OAAOA,KAAK8G,KAAK,WACZ5E,KAAK,SAAU4C,GACd,IAAI0C,EAAQ,GAQZ,OANA1C,EAAQpC,QAAQ,SAAUqE,GACxBS,EAAMT,GAAU,WACd,OAAOrC,EAAKoC,KAAKC,EAAQE,MAAMrD,UAAU8D,MAAMJ,KAAKG,eAIjDD,KAwBftC,EAAKtB,UAAU6C,MAAQ,WACrB,GAAwB,EAApBzG,KAAKoF,MAAMjE,OAAY,CAIzB,IAAI0D,EAAS7E,KAAK2H,aAClB,GAAI9C,EAAQ,CAEV,IAAItD,EAAKvB,KACLmH,EAAOnH,KAAKoF,MAAMwC,QAGtB,GAAIT,EAAK/C,SAASC,QAAQxC,QAAS,CAEjC,IAAIwC,EAAUQ,EAAOiC,KAAKK,EAAKJ,OAAQI,EAAKH,OAAQG,EAAK/C,UACtDlC,KAAKX,EAAGiF,YACRqB,MAAM,WAEDhD,EAAOiD,aACTvG,EAAGwG,cAAclD,GAEjBtD,EAAGgF,qBAELhF,EAAGkF,UAIqB,iBAAjBU,EAAKnE,SACdqB,EAAQrB,QAAQmE,EAAKnE,cAIvBzB,EAAGkF,WAeXvB,EAAKtB,UAAU+D,WAAa,WAG1B,IADA,IAAIxC,EAAUnF,KAAKmF,QACVjB,EAAI,EAAGA,EAAIiB,EAAQhE,OAAQ+C,IAAK,CACvC,IAAIW,EAASM,EAAQjB,GACrB,IAAsB,IAAlBW,EAAOmD,OACT,OAAOnD,EAIX,OAAIM,EAAQhE,OAASnB,KAAK8F,YAExBjB,EAAS7E,KAAKiI,uBACd9C,EAAQlD,KAAK4C,GACNA,GAGF,MASTK,EAAKtB,UAAUmE,cAAgB,SAASlD,GACtCI,EAAqBiD,YAAYrD,EAAOsD,WAExCtD,EAAOuD,YACPpI,KAAKqI,sBAAsBxD,IAQ7BK,EAAKtB,UAAUyE,sBAAwB,SAASxD,GAE9C,IAAIyD,EAAQtI,KAAKmF,QAAQkC,QAAQxC,IAClB,IAAXyD,GACFtI,KAAKmF,QAAQoD,OAAOD,EAAO,IAc/BpD,EAAKtB,UAAUwE,UAAY,SAAUI,EAAOxF,GAE1ChD,KAAKoF,MAAM1C,QAAQ,SAAUyE,GAC3BA,EAAK/C,SAAShC,OAAO,IAAIuB,MAAM,sBAEjC3D,KAAKoF,MAAMjE,OAAS,EAEpB,IAGIsH,EAHI,SAAU5D,GAChB7E,KAAKqI,sBAAsBxD,IAER6B,KAAK1G,MAEtB8D,EAAW,GAOf,OANc9D,KAAKmF,QAAQuC,QACnBhF,QAAQ,SAAUmC,GACxB,IAAI6D,EAAc7D,EAAO8D,mBAAmBH,EAAOxF,GAChDd,KAAKuG,GACR3E,EAAS7B,KAAKyG,KAETtH,EAAQyC,IAAIC,IAQrBoB,EAAKtB,UAAUgF,MAAQ,SAAUJ,GAC/BlD,QAAQC,KAAK,6DACbvF,KAAKoI,UAAUI,IAOjBtD,EAAKtB,UAAUiF,MAAQ,WACrB,IAAIC,EAAe9I,KAAKmF,QAAQhE,OAC5B4H,EAAc/I,KAAKmF,QAAQ6D,OAAO,SAAUnE,GAC9C,OAAOA,EAAOmD,SACb7G,OAEH,MAAO,CACL2H,aAAeA,EACfC,YAAeA,EACfE,YAAeH,EAAeC,EAE9BG,aAAelJ,KAAKoF,MAAMjE,OAC1BgI,YAAeJ,IAQnB7D,EAAKtB,UAAU2C,kBAAoB,WACjC,GAAIvG,KAAKqG,WACP,IAAI,IAAInC,EAAIlE,KAAKmF,QAAQhE,OAAQ+C,EAAIlE,KAAKqG,WAAYnC,IACpDlE,KAAKmF,QAAQlD,KAAKjC,KAAKiI,yBAU7B/C,EAAKtB,UAAUqE,qBAAuB,WACpC,OAAO,IAAIjD,EAAchF,KAAK2E,OAAQ,CACpCa,SAAUxF,KAAKwF,SACfC,SAAUzF,KAAKyF,SACf0C,UAAWlD,EAAqBmE,wBAAwBpJ,KAAK0F,gBAC7DC,WAAY3F,KAAK2F,cA4CrB/F,EAAOD,QAAUuF,GAKX,SAAUtF,EAAQD,EAASO,GAEjC,aAGA,IAAIkB,EAAUlB,EAAoB,GAC9BuE,EAAcvE,EAAoB,GAClCK,EAAqBL,EAAoB,GAE7C,SAASyG,IACP,IAAI0C,EAAgBC,IACpB,IAAKD,EACH,MAAM,IAAI1F,MAAM,+EAGlB,OAAO0F,EAIT,SAASE,IAEP,GAAsB,mBAAXC,SAA4C,iBAAXA,QAA+D,mBAAjCA,OAAO5F,UAAUU,aACzF,MAAM,IAAIX,MAAM,yCAIpB,SAAS2F,IACP,IACE,OAAO/I,EAAmB,kBAC1B,MAAMsC,GACN,GAAqB,iBAAVA,GAAgC,OAAVA,GAAiC,qBAAfA,EAAM4G,KAEvD,OAAO,KAEP,MAAM5G,GAmDZ,SAAS6G,EAAmB/E,EAAQ6E,GAElC,IAAI3E,EAAS,IAAI2E,EAAO7E,GAYxB,OAVAE,EAAO8E,iBAAkB,EAEzB9E,EAAO+E,GAAK,SAAUC,EAAOtG,GAC3BvD,KAAK8J,iBAAiBD,EAAO,SAAUpG,GACrCF,EAASE,EAAQsG,SAGrBlF,EAAOmF,KAAO,SAAUvG,GACtBzD,KAAKiK,YAAYxG,IAEZoB,EAGT,SAASqF,EAAwBvF,EAAQ0E,GACvC,IAAIxE,EAAS,IAAIwE,EAAcG,OAAO7E,EAAQ,CAC5CwF,QAAQ,EACRC,QAAQ,IAgBV,OAdAvF,EAAOwF,gBAAiB,EAExBxF,EAAOmF,KAAO,SAASvG,GACrBzD,KAAKiK,YAAYxG,IAGnBoB,EAAOyF,KAAO,WACZtK,KAAKoI,aAGPvD,EAAO0F,WAAa,WAClBvK,KAAKoI,aAGAvD,EAGT,SAAS2F,EAAmB7F,EAAQC,EAAS6F,GAE3C,IAAI5F,EAAS4F,EAAcC,KACzB/F,EACAC,EAAQY,SACRZ,EAAQa,UAIV,OADAZ,EAAO8F,gBAAiB,EACjB9F,EAIT,SAAS+F,EAAmBC,GAC1BA,EAAOA,GAAQ,GAEf,IAAIC,EAAkBrK,QAAQsK,SAASC,KAAK,KACxCC,GAA4D,IAA1CH,EAAgBzD,QAAQ,aAC1C6D,GAAuD,IAA5CJ,EAAgBzD,QAAQ,eAEnC0D,EAAW,GAef,OAdIE,IACFF,EAAS9I,KAAK,aAAe4I,EAAK1C,WAE9B+C,GACFH,EAAS9I,KAAK,gBAIlBxB,QAAQsK,SAASrI,QAAQ,SAASyI,IACW,EAAvCA,EAAI9D,QAAQ,yBACd0D,EAAS9I,KAAKkJ,KAIXC,OAAOC,OAAO,GAAIR,EAAM,CAC7BrF,SAAUqF,EAAKrF,SACfC,SAAU2F,OAAOC,OAAO,GAAIR,EAAKpF,SAAU,CACzCsF,UAAWF,EAAKpF,UAAYoF,EAAKpF,SAASsF,UAAY,IACrDO,OAAOP,OA6Bd,SAAS/F,EAAcL,EAAQ4G,GAC7B,IAAIhK,EAAKvB,KACL4E,EAAU2G,GAAY,GA2C1B,SAASC,EAAQ3I,GAOf,IAAK,IAAI4I,KANTlK,EAAGuG,YAAa,EACZvG,EAAGmK,aAAenK,EAAGoK,oBACvBpK,EAAGoK,mBAAmBpK,GAExBA,EAAGmK,aAAc,EAEFnK,EAAGqK,gBACUC,IAAtBtK,EAAGqK,WAAWH,IAChBlK,EAAGqK,WAAWH,GAAIrH,SAAShC,OAAOS,GAGtCtB,EAAGqK,WAAaR,OAAOU,OAAO,MArDhC9L,KAAK2E,OAASA,GA5JhB,WACE,GAA6B,YAAzBF,EAAYjE,SAed,OAAOuL,UAAY,aAbnB,GAAoB,oBAATC,KACT,MAAM,IAAIrI,MAAM,qCAElB,IAAKsI,OAAOC,KAA6C,mBAA/BD,OAAOC,IAAIC,gBACnC,MAAM,IAAIxI,MAAM,oDAIlB,IAAIyI,EAAO,IAAIJ,KAAK,CAAC9L,EAAoB,IAAK,CAACmM,KAAM,oBACrD,OAAOJ,OAAOC,IAAIC,gBAAgBC,GAgJZE,GACxBtM,KAAK6E,OAzIP,SAAqBF,EAAQC,GAC3B,GAA2B,QAAvBA,EAAQe,WAEV,OADA4D,IACOG,EAAmB/E,EAAQ6E,QAC7B,GAA2B,WAAvB5E,EAAQe,WAEjB,OAAOuE,EAAwBvF,EAD/B0E,EAAgB1C,KAEX,GAA2B,YAAvB/B,EAAQe,YAA6Bf,EAAQe,WAEjD,CACL,GAA6B,YAAzBlB,EAAYjE,SAEd,OADA+I,IACOG,EAAmB/E,EAAQ6E,QAGlC,IAAIH,EAAgBC,IACpB,OAAID,EACKa,EAAwBvF,EAAQ0E,GAEhCmB,EAAmB7F,EAAQiG,EAAmBhG,GAAUrE,EAAmB,kBAXtF,OAAOiK,EAAmB7F,EAAQiG,EAAmBhG,GAAUrE,EAAmB,kBAiItEgM,CAAYvM,KAAK2E,OAAQC,GACvC5E,KAAKmI,UAAYvD,EAAQuD,UAGpBxD,IACH3E,KAAK6E,OAAO2H,OAAQ,GAItBxM,KAAKyM,aAAe,GACpBzM,KAAK6E,OAAO+E,GAAG,UAAW,SAAU8C,GAClC,GAAwB,iBAAbA,GAAsC,UAAbA,EAClCnL,EAAGsD,OAAO2H,OAAQ,EA8CpBjL,EAAGkL,aAAa/J,QAAQnB,EAAGsD,OAAOmF,KAAKtD,KAAKnF,EAAGsD,SAC/CtD,EAAGkL,aAAe,OA7CX,CAEL,IAAIhB,EAAKiB,EAASjB,GACdtE,EAAO5F,EAAGqK,WAAWH,QACZI,IAAT1E,WAEK5F,EAAGqK,WAAWH,IAGE,IAAnBlK,EAAGmK,aAELnK,EAAG6G,YAIDsE,EAAS7J,MACXsE,EAAK/C,SAAShC,OAtDxB,SAAwBuK,GAItB,IAHA,IAAIC,EAAO,IAAIjJ,MAAM,IACjBkJ,EAAQzB,OAAO0B,KAAKH,GAEfzI,EAAI,EAAGA,EAAI2I,EAAM1L,OAAQ+C,IAChC0I,EAAKC,EAAM3I,IAAMyI,EAAIE,EAAM3I,IAG7B,OAAO0I,EA8CsBG,CAAcL,EAAS7J,QAG5CsE,EAAK/C,SAASjC,QAAQuK,EAASjK,YA6BvC,IAAIoC,EAAS7E,KAAK6E,OAElB7E,KAAK6E,OAAO+E,GAAG,QAAS4B,GACxBxL,KAAK6E,OAAO+E,GAAG,OAAQ,SAAUoD,EAAUC,GACzC,IAAIxJ,EAAU,8CAEdA,GAAW,kBAAoBuJ,EAAW,MAC1CvJ,GAAW,oBAAsBwJ,EAAa,MAE9CxJ,GAAW,2BAA8BlC,EAAGoD,OAAS,MACrDlB,GAAW,mBAAsBoB,EAAOqI,UAAY,MACpDzJ,GAAW,mBAAqBoB,EAAOsI,UAAY,MAEnD1J,GAAW,gBAAkBoB,EAAOsF,OAAS,MAC7C1G,GAAW,gBAAkBoB,EAAOuF,OAAS,MAE7CoB,EAAQ,IAAI7H,MAAMF,MAGpBzD,KAAK4L,WAAaR,OAAOU,OAAO,MAEhC9L,KAAK0L,aAAc,EACnB1L,KAAK8H,YAAa,EAClB9H,KAAK2L,mBAAqB,KAC1B3L,KAAKoN,OAAS,EAOhBpI,EAAcpB,UAAUkB,QAAU,WAChC,OAAO9E,KAAK8G,KAAK,YAUnB9B,EAAcpB,UAAUkD,KAAO,SAASC,EAAQC,EAAQ5C,GAEpDA,EADGA,GACQhD,EAAQ+C,QAIrB,IAAIsH,IAAOzL,KAAKoN,OAGhBpN,KAAK4L,WAAWH,GAAM,CACpBA,GAAIA,EACJrH,SAAUA,GAIZ,IAAIiJ,EAAU,CACZ5B,GAAIA,EACJ1E,OAAQA,EACRC,OAAQA,GAGNhH,KAAK8H,WACP1D,EAAShC,OAAO,IAAIuB,MAAM,yBACjB3D,KAAK6E,OAAO2H,MAErBxM,KAAK6E,OAAOmF,KAAKqD,GAEjBrN,KAAKyM,aAAaxK,KAAKoL,GAIzB,IAAI9L,EAAKvB,KAeT,OAdAoE,EAASC,QACNwD,MAAM,SAAUhF,GACf,KAAIA,aAAiBzB,EAAQ2B,mBAAqBF,aAAiBzB,EAAQgC,cAQzE,MAAMP,SALCtB,EAAGqK,WAAWH,GAGrBlK,EAAG6G,WAAU,KAMZhE,EAASC,SAOlBW,EAAcpB,UAAUoE,KAAO,WAC7B,OAA6C,EAAtCoD,OAAO0B,KAAK9M,KAAK4L,YAAYzK,QAWtC6D,EAAcpB,UAAUwE,UAAY,SAAUI,EAAOjF,GACnD,GAAIiF,EAAO,CAET,IAAK,IAAIiD,KAAMzL,KAAK4L,gBACUC,IAAxB7L,KAAK4L,WAAWH,IAClBzL,KAAK4L,WAAWH,GAAIrH,SAAShC,OAAO,IAAIuB,MAAM,sBAGlD3D,KAAK4L,WAAaR,OAAOU,OAAO,MAMlC,GAHwB,mBAAbvI,IACTvD,KAAK2L,mBAAqBpI,GAEvBvD,KAAKgI,OAsBRhI,KAAK0L,aAAc,MAtBH,CAEhB,GAAI1L,KAAK6E,OAAQ,CACf,GAAgC,mBAArB7E,KAAK6E,OAAOyF,KACrBtK,KAAK6E,OAAOyF,WAET,CAAA,GAAqC,mBAA1BtK,KAAK6E,OAAOuD,UAI1B,MAAM,IAAIzE,MAAM,8BAHhB3D,KAAK6E,OAAOuD,YAKdpI,KAAK6E,OAAS,KAEhB7E,KAAK0L,aAAc,EACnB1L,KAAK8H,YAAa,EACd9H,KAAK2L,oBACP3L,KAAK2L,mBAAmB3L,QAmB9BgF,EAAcpB,UAAU+E,mBAAqB,SAAUH,EAAOxF,GAC5D,IAAIoB,EAAWhD,EAAQ+C,QAOvB,OANInB,IACFoB,EAASC,QAAQrB,QAAUA,GAE7BhD,KAAKoI,UAAUI,EAAO,SAAS3D,GAC7BT,EAASjC,QAAQ0C,KAEZT,EAASC,SAGlBzE,EAAOD,QAAUqF,EACjBpF,EAAOD,QAAQ2N,yBAA2BhE,EAC1C1J,EAAOD,QAAQ4N,oBAAsB/C,EACrC5K,EAAOD,QAAQ6N,oBAAsB9D,EACrC9J,EAAOD,QAAQ8N,yBAA2BvD,EAC1CtK,EAAOD,QAAQgH,oBAAsBA,GAK/B,SAAU/G,EAAQD,GAOxBC,EAAOD,QAAU,gzFAKX,SAAUC,EAAQD,EAASO,GAEjC,aAKA,SAASwN,IACP1N,KAAK2N,MAAQvC,OAAOU,OAAO,MAC3B9L,KAAKmB,OAAS,GAHhBvB,EAAOD,QAAU+N,GAME9J,UAAUwF,wBAA0B,SAASwE,GAC9D,MAAgC,IAAzB5N,KAAK2N,MAAMC,IAChBA,IAGF,GAZc,OAYVA,EACF,MAAM,IAAIjK,MAAM,wCAA0CiK,EAAW,YAKvE,OAFA5N,KAAK2N,MAAMC,IAAY,EACvB5N,KAAKmB,SACEyM,GAGTF,EAAmB9J,UAAUsE,YAAc,SAAS2F,UAC3C7N,KAAK2N,MAAME,GAClB7N,KAAKmB,WAOD,SAAUvB,OAAQD,QAASO,qBAQjC,IAAIK,mBAAqBiE,KACrB,0HAOAK,OAAS,GACb,GAAoB,oBAAT9E,MAA+C,mBAAhBkK,aAA0D,mBAArBH,iBAE7EjF,OAAO+E,GAAK,SAAUC,EAAOtG,GAC3BuG,iBAAiBD,EAAO,SAAUpG,GAChCF,EAASE,EAAQsG,SAGrBlF,OAAOmF,KAAO,SAAUvG,GACtBwG,YAAYxG,QAGX,CAAA,GAAuB,oBAAZhD,QA8Bd,MAAM,IAAIkD,MAAM,uCA3BhB,IAAI0F,cACJ,IACEA,cAAgB9I,mBAAmB,kBACnC,MAAMsC,GACN,GAAqB,iBAAVA,GAAgC,OAAVA,GAAgC,oBAAdA,EAAM4G,KAGvD,MAAM5G,EAIV,GAAIwG,eAE2B,OAA7BA,cAAcyE,WAAqB,CACnC,IAAIA,WAAczE,cAAcyE,WAChCjJ,OAAOmF,KAAO8D,WAAW7D,YAAYvD,KAAKoH,YAC1CjJ,OAAO+E,GAAKkE,WAAWlE,GAAGlD,KAAKoH,iBAE/BjJ,OAAO+E,GAAKnJ,QAAQmJ,GAAGlD,KAAKjG,SAC5BoE,OAAOmF,KAAOvJ,QAAQuJ,KAAKtD,KAAKjG,SAEhCoE,OAAO+E,GAAG,aAAc,WACtBnJ,QAAQsN,KAAK,KAQnB,SAASC,aAAanL,GACpB,OAAOuI,OAAO6C,oBAAoBpL,GAAOqL,OAAO,SAASC,EAAS5J,GAChE,OAAO6G,OAAOgD,eAAeD,EAAS5J,EAAM,CAC/CqC,MAAO/D,EAAM0B,GACb8J,YAAY,KAER,IASL,SAASC,UAAU1H,GACjB,OAAOA,GAAgC,mBAAfA,EAAM1E,MAAgD,mBAAhB0E,EAAMiB,MAItEhD,OAAOC,QAAU,GAQjBD,OAAOC,QAAQyJ,IAAM,SAASA,IAAI5L,GAAI6L,MACpC,IAAIjM,EAAIiC,KAAK,IAAM7B,GAAK,KACxB,OAAOJ,EAAEkM,MAAMlM,EAAGiM,OAOpB3J,OAAOC,QAAQA,QAAU,WACvB,OAAOsG,OAAO0B,KAAKjI,OAAOC,UAG5BD,OAAO+E,GAAG,UAAW,SAAUyD,GAC7B,IACE,IAAItG,EAASlC,OAAOC,QAAQuI,EAAQtG,QAEpC,IAAIA,EAgCF,MAAM,IAAIpD,MAAM,mBAAqB0J,EAAQtG,OAAS,KA9BtD,IAAItE,EAASsE,EAAO0H,MAAM1H,EAAQsG,EAAQrG,QAEtCsH,UAAU7L,GAEZA,EACKP,KAAK,SAAUO,GACdoC,OAAOmF,KAAK,CACVyB,GAAI4B,EAAQ5B,GACZhJ,OAAQA,EACRI,MAAO,SAGVgF,MAAM,SAAUlH,GACfkE,OAAOmF,KAAK,CACVyB,GAAI4B,EAAQ5B,GACZhJ,OAAQ,KACRI,MAAOmL,aAAarN,OAM5BkE,OAAOmF,KAAK,CACVyB,GAAI4B,EAAQ5B,GACZhJ,OAAQA,EACRI,MAAO,OAQf,MAAOlC,GACLkE,OAAOmF,KAAK,CACVyB,GAAI4B,EAAQ5B,GACZhJ,OAAQ,KACRI,MAAOmL,aAAarN,QAS1BkE,OAAO6J,SAAW,SAAU5J,GAE1B,GAAIA,EACF,IAAK,IAAIP,KAAQO,EACXA,EAAQ6J,eAAepK,KACzBM,OAAOC,QAAQP,GAAQO,EAAQP,IAKrCM,OAAOmF,KAAK,UAKZrK,QAAQoF,IAAMF,OAAO6J,WAvgDTE,EAAmB,GA4BvB1O,EAAoB2O,EAAI5O,EAGxBC,EAAoB4O,EAAIF,EAGxB1O,EAAoB6O,EAAI,SAASpP,EAAS4E,EAAMyK,GAC3C9O,EAAoB+O,EAAEtP,EAAS4E,IAClC6G,OAAOgD,eAAezO,EAAS4E,EAAM,CAAE8J,YAAY,EAAMa,IAAKF,KAKhE9O,EAAoBiP,EAAI,SAASxP,GACX,oBAAXyP,QAA0BA,OAAOC,aAC1CjE,OAAOgD,eAAezO,EAASyP,OAAOC,YAAa,CAAEzI,MAAO,WAE7DwE,OAAOgD,eAAezO,EAAS,aAAc,CAAEiH,OAAO,KAQvD1G,EAAoBoP,EAAI,SAAS1I,EAAO2I,GAEvC,GADU,EAAPA,IAAU3I,EAAQ1G,EAAoB0G,IAC/B,EAAP2I,EAAU,OAAO3I,EACpB,GAAW,EAAP2I,GAA8B,iBAAV3I,GAAsBA,GAASA,EAAM4I,WAAY,OAAO5I,EAChF,IAAI6I,EAAKrE,OAAOU,OAAO,MAGvB,GAFA5L,EAAoBiP,EAAEM,GACtBrE,OAAOgD,eAAeqB,EAAI,UAAW,CAAEpB,YAAY,EAAMzH,MAAOA,IACtD,EAAP2I,GAA4B,iBAAT3I,EAAmB,IAAI,IAAI8I,KAAO9I,EAAO1G,EAAoB6O,EAAEU,EAAIC,EAAK,SAASA,GAAO,OAAO9I,EAAM8I,IAAQhJ,KAAK,KAAMgJ,IAC9I,OAAOD,GAIRvP,EAAoByP,EAAI,SAAS/P,GAChC,IAAIoP,EAASpP,GAAUA,EAAO4P,WAC7B,WAAwB,OAAO5P,EAAgB,SAC/C,WAA8B,OAAOA,GAEtC,OADAM,EAAoB6O,EAAEC,EAAQ,IAAKA,GAC5BA,GAIR9O,EAAoB+O,EAAI,SAASW,EAAQC,GAAY,OAAOzE,OAAOxH,UAAU+K,eAAerH,KAAKsI,EAAQC,IAGzG3P,EAAoB+D,EAAI,GAIjB/D,EAAoBA,EAAoBmC,EAAI,GA9EnD,SAASnC,EAAoB4P,GAG5B,GAAGlB,EAAiBkB,GACnB,OAAOlB,EAAiBkB,GAAUnQ,QAGnC,IAAIC,EAASgP,EAAiBkB,GAAY,CACzC5L,EAAG4L,EACHC,GAAG,EACHpQ,QAAS,IAUV,OANAM,EAAQ6P,GAAUxI,KAAK1H,EAAOD,QAASC,EAAQA,EAAOD,QAASO,GAG/DN,EAAOmQ,GAAI,EAGJnQ,EAAOD,QAzBT,IAAUM,EAEZ2O"}

dist/workerpool.min.js

@@ -7,4 +7,4 @@ /**
  *
- * @version 5.0.3
- * @date    2019-12-23
+ * @version 5.0.4
+ * @date    2019-12-31
  *
@@ -26,3 +26,3 @@ * @license
  */
-!function(e,r){"object"==typeof exports&&"object"==typeof module?module.exports=r():"function"==typeof define&&define.amd?define("workerpool",[],r):"object"==typeof exports?exports.workerpool=r():e.workerpool=r()}("undefined"!=typeof self?self:this,function(){return d=[function(e,r,t){function o(e){return void 0!==e&&null!=e.versions&&null!=e.versions.node}var n=t(2);e.exports.isNode=o,e.exports.platform="undefined"!=typeof process&&o(process)?"node":"browser",e.exports.isMainThread="node"===e.exports.platform?!process.connected:"undefined"!=typeof Window,e.exports.cpus="browser"===e.exports.platform?self.navigator.hardwareConcurrency:n("os").cpus().length},function(e,r,t){"use strict";function a(e,t){var o=this;if(!(this instanceof a))throw new SyntaxError("Constructor must be called with the new operator");if("function"!=typeof e)throw new SyntaxError("Function parameter handler(resolve, reject) missing");var n=[],i=[];this.resolved=!1,this.rejected=!1,this.pending=!0;var s=function(e,r){n.push(e),i.push(r)};this.then=function(n,i){return new a(function(e,r){var t=n?c(n,e,r):e,o=i?c(i,e,r):r;s(t,o)},o)};var r=function(t){return o.resolved=!0,o.rejected=!1,o.pending=!1,n.forEach(function(e){e(t)}),s=function(e,r){e(t)},r=u=function(){},o},u=function(t){return o.resolved=!1,o.rejected=!0,o.pending=!1,i.forEach(function(e){e(t)}),s=function(e,r){r(t)},r=u=function(){},o};this.cancel=function(){return t?t.cancel():u(new f),o},this.timeout=function(e){if(t)t.timeout(e);else{var r=setTimeout(function(){u(new p("Promise timed out after "+e+" ms"))},e);o.always(function(){clearTimeout(r)})}return o},e(function(e){r(e)},function(e){u(e)})}function c(t,o,n){return function(e){try{var r=t(e);r&&"function"==typeof r.then&&"function"==typeof r.catch?r.then(o,n):o(r)}catch(e){n(e)}}}function f(e){this.message=e||"promise cancelled",this.stack=(new Error).stack}function p(e){this.message=e||"timeout exceeded",this.stack=(new Error).stack}a.prototype.catch=function(e){return this.then(null,e)},a.prototype.always=function(e){return this.then(e,e)},a.all=function(e){return new a(function(t,o){var n=e.length,i=[];n?e.forEach(function(e,r){e.then(function(e){i[r]=e,0==--n&&t(i)},function(e){n=0,o(e)})}):t(i)})},a.defer=function(){var t={};return t.promise=new a(function(e,r){t.resolve=e,t.reject=r}),t},(f.prototype=new Error).constructor=Error,f.prototype.name="CancellationError",a.CancellationError=f,(p.prototype=new Error).constructor=Error,p.prototype.name="TimeoutError",a.TimeoutError=p,e.exports=a},function(module,exports){var requireFoolWebpack=eval("typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \" + module + \" not found.') }");module.exports=requireFoolWebpack},function(e,r,t){var o=t(0);r.pool=function(e,r){return new(t(4))(e,r)},r.worker=function(e){var r=t(8);r.add(e)},r.Promise=t(1),r.platform=o.platform,r.isMainThread=o.isMainThread,r.cpus=o.cpus},function(e,r,t){var s=t(1),o=t(5),n=t(0),i=new(t(7));function u(e,r){"string"==typeof e?this.script=e||null:(this.script=null,r=e),this.workers=[],this.tasks=[],(r=r||{}).nodeWorker&&console.warn('WARNING: Option "nodeWorker" is deprecated since workerpool@5.0.0. Please use "workerType" instead.'),this.forkArgs=r.forkArgs||[],this.forkOpts=r.forkOpts||{},this.debugPortStart=r.debugPortStart||43210,this.nodeWorker=r.nodeWorker,this.workerType=r.workerType||r.nodeWorker||"auto",this.maxQueueSize=r.maxQueueSize||1/0,r&&"maxWorkers"in r?(function(e){if(!a(e)||!c(e)||e<1)throw new TypeError("Option maxWorkers must be an integer number >= 1")}(r.maxWorkers),this.maxWorkers=r.maxWorkers):this.maxWorkers=Math.max((n.cpus||4)-1,1),r&&"minWorkers"in r&&("max"===r.minWorkers?this.minWorkers=this.maxWorkers:(function(e){if(!a(e)||!c(e)||e<0)throw new TypeError("Option minWorkers must be an integer number >= 0")}(r.minWorkers),this.minWorkers=r.minWorkers,this.maxWorkers=Math.max(this.minWorkers,this.maxWorkers)),this._ensureMinWorkers()),this._boundNext=this._next.bind(this),"thread"===this.workerType&&o.ensureWorkerThreads()}function a(e){return"number"==typeof e}function c(e){return Math.round(e)==e}u.prototype.exec=function(e,r){if(r&&!Array.isArray(r))throw new TypeError('Array expected as argument "params"');if("string"==typeof e){var t=s.defer();if(this.tasks.length>=this.maxQueueSize)throw new Error("Max queue size of "+this.maxQueueSize+" reached");var o=this.tasks,n={method:e,params:r,resolver:t,timeout:null};o.push(n);var i=t.promise.timeout;return t.promise.timeout=function(e){return-1!==o.indexOf(n)?(n.timeout=e,t.promise):i.call(t.promise,e)},this._next(),t.promise}if("function"==typeof e)return this.exec("run",[String(e),r]);throw new TypeError('Function or string expected as argument "method"')},u.prototype.proxy=function(){if(0<arguments.length)throw new Error("No arguments expected");var t=this;return this.exec("methods").then(function(e){var r={};return e.forEach(function(e){r[e]=function(){return t.exec(e,Array.prototype.slice.call(arguments))}}),r})},u.prototype._next=function(){if(0<this.tasks.length){var e=this._getWorker();if(e){var r=this,t=this.tasks.shift();if(t.resolver.promise.pending){var o=e.exec(t.method,t.params,t.resolver).then(r._boundNext).catch(function(){e.terminated&&(r._removeWorker(e),r._ensureMinWorkers()),r._next()});"number"==typeof t.timeout&&o.timeout(t.timeout)}else r._next()}}},u.prototype._getWorker=function(){for(var e=this.workers,r=0;r<e.length;r++){var t=e[r];if(!1===t.busy())return t}return e.length<this.maxWorkers?(t=this._createWorkerHandler(),e.push(t),t):null},u.prototype._removeWorker=function(e){i.releasePort(e.debugPort),e.terminate(),this._removeWorkerFromList(e)},u.prototype._removeWorkerFromList=function(e){var r=this.workers.indexOf(e);-1!==r&&this.workers.splice(r,1)},u.prototype.terminate=function(t,o){this.tasks.forEach(function(e){e.resolver.reject(new Error("Pool terminated"))}),this.tasks.length=0;var n=function(e){this._removeWorkerFromList(e)}.bind(this),i=[];return this.workers.slice().forEach(function(e){var r=e.terminateAndNotify(t,o).then(n);i.push(r)}),s.all(i)},u.prototype.clear=function(e){console.warn("Pool.clear() is deprecated. Use Pool.terminate() instead."),this.terminate(e)},u.prototype.stats=function(){var e=this.workers.length,r=this.workers.filter(function(e){return e.busy()}).length;return{totalWorkers:e,busyWorkers:r,idleWorkers:e-r,pendingTasks:this.tasks.length,activeTasks:r}},u.prototype._ensureMinWorkers=function(){if(this.minWorkers)for(var e=this.workers.length;e<this.minWorkers;e++)this.workers.push(this._createWorkerHandler())},u.prototype._createWorkerHandler=function(){return new o(this.script,{forkArgs:this.forkArgs,forkOpts:this.forkOpts,debugPort:i.nextAvailableStartingAt(this.debugPortStart),workerType:this.workerType})},e.exports=u},function(e,r,s){"use strict";var u=s(1),a=s(0),c=s(2);function f(){var e=d();if(!e)throw new Error("WorkerPool: workerType = 'thread' is not supported, Node >= 11.7.0 required");return e}function p(){if("function"!=typeof Worker&&("object"!=typeof Worker||"function"!=typeof Worker.prototype.constructor))throw new Error("WorkerPool: Web Workers not supported")}function d(){try{return c("worker_threads")}catch(e){if("object"==typeof e&&null!==e&&"MODULE_NOT_FOUND"===e.code)return null;throw e}}function h(e,r){var t=new r(e);return t.isBrowserWorker=!0,t.on=function(e,r){this.addEventListener(e,function(e){r(e.data)})},t.send=function(e){this.postMessage(e)},t}function l(e,r){var t=new r.Worker(e,{stdout:!1,stderr:!1});return t.isWorkerThread=!0,t.send=function(e){this.postMessage(e)},t.kill=function(){this.terminate()},t.disconnect=function(){this.terminate()},t}function k(e,r,t){var o=t.fork(e,r.forkArgs,r.forkOpts);return o.isChildProcess=!0,o}function m(e){e=e||{};var r=process.execArgv.join(" "),t=-1!==r.indexOf("--inspect"),o=-1!==r.indexOf("--debug-brk"),n=[];return t&&(n.push("--inspect="+e.debugPort),o&&n.push("--debug-brk")),process.execArgv.forEach(function(e){-1<e.indexOf("--max-old-space-size")&&n.push(e)}),Object.assign({},e,{forkArgs:e.forkArgs,forkOpts:Object.assign({},e.forkOpts,{execArgv:(e.forkOpts&&e.forkOpts.execArgv||[]).concat(n)})})}function t(e,r){var o=this,t=r||{};function n(e){for(var r in o.terminated=!0,o.terminating&&o.terminationHandler&&o.terminationHandler(o),o.terminating=!1,o.processing)void 0!==o.processing[r]&&o.processing[r].resolver.reject(e);o.processing=Object.create(null)}this.script=e||function(){if("browser"!==a.platform)return __dirname+"/worker.js";if("undefined"==typeof Blob)throw new Error("Blob not supported by the browser");if(!window.URL||"function"!=typeof window.URL.createObjectURL)throw new Error("URL.createObjectURL not supported by the browser");var e=new Blob([s(6)],{type:"text/javascript"});return window.URL.createObjectURL(e)}(),this.worker=function(e,r){if("web"===r.workerType)return p(),h(e,Worker);if("thread"===r.workerType)return l(e,t=f());if("process"!==r.workerType&&r.workerType){if("browser"===a.platform)return p(),h(e,Worker);var t=d();return t?l(e,t):k(e,m(r),c("child_process"))}return k(e,m(r),c("child_process"))}(this.script,t),this.debugPort=t.debugPort,e||(this.worker.ready=!0),this.requestQueue=[],this.worker.on("message",function(e){if("string"==typeof e&&"ready"===e)o.worker.ready=!0,o.requestQueue.forEach(o.worker.send.bind(o.worker)),o.requestQueue=[];else{var r=e.id,t=o.processing[r];void 0!==t&&(delete o.processing[r],!0===o.terminating&&o.terminate(),e.error?t.resolver.reject(function(e){for(var r=new Error(""),t=Object.keys(e),o=0;o<t.length;o++)r[t[o]]=e[t[o]];return r}(e.error)):t.resolver.resolve(e.result))}});var i=this.worker;this.worker.on("error",n),this.worker.on("exit",function(e,r){var t="Workerpool Worker terminated Unexpectedly\n";t+="    exitCode: `"+e+"`\n",t+="    signalCode: `"+r+"`\n",t+="    workerpool.script: `"+o.script+"`\n",t+="    spawnArgs: `"+i.spawnargs+"`\n",t+="    spawnfile: `"+i.spawnfile+"`\n",t+="    stdout: `"+i.stdout+"`\n",t+="    stderr: `"+i.stderr+"`\n",n(new Error(t))}),this.processing=Object.create(null),this.terminating=!1,this.terminated=!1,this.terminationHandler=null,this.lastId=0}t.prototype.methods=function(){return this.exec("methods")},t.prototype.exec=function(e,r,t){t=t||u.defer();var o=++this.lastId;this.processing[o]={id:o,resolver:t};var n={id:o,method:e,params:r};this.terminated?t.reject(new Error("Worker is terminated")):this.worker.ready?this.worker.send(n):this.requestQueue.push(n);var i=this;return t.promise.catch(function(e){if(!(e instanceof u.CancellationError||e instanceof u.TimeoutError))throw e;delete i.processing[o],i.terminate(!0)}),t.promise},t.prototype.busy=function(){return 0<Object.keys(this.processing).length},t.prototype.terminate=function(e,r){if(e){for(var t in this.processing)void 0!==this.processing[t]&&this.processing[t].resolver.reject(new Error("Worker terminated"));this.processing=Object.create(null)}if("function"==typeof r&&(this.terminationHandler=r),this.busy())this.terminating=!0;else{if(this.worker){if("function"==typeof this.worker.kill)this.worker.kill();else{if("function"!=typeof this.worker.terminate)throw new Error("Failed to terminate worker");this.worker.terminate()}this.worker=null}this.terminating=!1,this.terminated=!0,this.terminationHandler&&this.terminationHandler(this)}},t.prototype.terminateAndNotify=function(e,r){var t=u.defer();return r&&(t.promise.timeout=r),this.terminate(e,function(e){t.resolve(e)}),t.promise},e.exports=t,e.exports._tryRequireWorkerThreads=d,e.exports._setupProcessWorker=k,e.exports._setupBrowserWorker=h,e.exports._setupWorkerThreadWorker=l,e.exports.ensureWorkerThreads=f},function(e,r){e.exports='!function(o){var n={};function t(e){if(n[e])return n[e].exports;var r=n[e]={i:e,l:!1,exports:{}};return o[e].call(r.exports,r,r.exports,t),r.l=!0,r.exports}t.m=o,t.c=n,t.d=function(e,r,o){t.o(e,r)||Object.defineProperty(e,r,{enumerable:!0,get:o})},t.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},t.t=function(r,e){if(1&e&&(r=t(r)),8&e)return r;if(4&e&&"object"==typeof r&&r&&r.__esModule)return r;var o=Object.create(null);if(t.r(o),Object.defineProperty(o,"default",{enumerable:!0,value:r}),2&e&&"string"!=typeof r)for(var n in r)t.d(o,n,function(e){return r[e]}.bind(null,n));return o},t.n=function(e){var r=e&&e.__esModule?function(){return e.default}:function(){return e};return t.d(r,"a",r),r},t.o=function(e,r){return Object.prototype.hasOwnProperty.call(e,r)},t.p="",t(t.s=0)}([function(module,exports,__webpack_require__){var requireFoolWebpack=eval("typeof require !== \'undefined\' ? require : function (module) { throw new Error(\'Module \\" + module + \\" not found.\') }"),worker={};if("undefined"!=typeof self&&"function"==typeof postMessage&&"function"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,function(e){r(e.data)})},worker.send=function(e){postMessage(e)};else{if("undefined"==typeof process)throw new Error("Script must be executed as a worker");var WorkerThreads;try{WorkerThreads=requireFoolWebpack("worker_threads")}catch(e){if("object"!=typeof e||null===e||"MODULE_NOT_FOUND"!=e.code)throw e}if(WorkerThreads&&null!==WorkerThreads.parentPort){var parentPort=WorkerThreads.parentPort;worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)}else worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on("disconnect",function(){process.exit(1)})}function convertError(o){return Object.getOwnPropertyNames(o).reduce(function(e,r){return Object.defineProperty(e,r,{value:o[r],enumerable:!0})},{})}function isPromise(e){return e&&"function"==typeof e.then&&"function"==typeof e.catch}worker.methods={},worker.methods.run=function run(fn,args){var f=eval("("+fn+")");return f.apply(f,args)},worker.methods.methods=function(){return Object.keys(worker.methods)},worker.on("message",function(r){try{var e=worker.methods[r.method];if(!e)throw new Error(\'Unknown method "\'+r.method+\'"\');var o=e.apply(e,r.params);isPromise(o)?o.then(function(e){worker.send({id:r.id,result:e,error:null})}).catch(function(e){worker.send({id:r.id,result:null,error:convertError(e)})}):worker.send({id:r.id,result:o,error:null})}catch(e){worker.send({id:r.id,result:null,error:convertError(e)})}}),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send("ready")},exports.add=worker.register}]);'},function(e,r,t){"use strict";function o(){this.ports=Object.create(null),this.length=0}(e.exports=o).prototype.nextAvailableStartingAt=function(e){for(;!0===this.ports[e];)e++;if(65535<=e)throw new Error("WorkerPool debug port limit reached: "+e+">= 65535");return this.ports[e]=!0,this.length++,e},o.prototype.releasePort=function(e){delete this.ports[e],this.length--}},function(module,exports,__webpack_require__){var requireFoolWebpack=eval("typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \" + module + \" not found.') }"),worker={};if("undefined"!=typeof self&&"function"==typeof postMessage&&"function"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,function(e){r(e.data)})},worker.send=function(e){postMessage(e)};else{if("undefined"==typeof process)throw new Error("Script must be executed as a worker");var WorkerThreads;try{WorkerThreads=requireFoolWebpack("worker_threads")}catch(e){if("object"!=typeof e||null===e||"MODULE_NOT_FOUND"!=e.code)throw e}if(WorkerThreads&&null!==WorkerThreads.parentPort){var parentPort=WorkerThreads.parentPort;worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)}else worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on("disconnect",function(){process.exit(1)})}function convertError(t){return Object.getOwnPropertyNames(t).reduce(function(e,r){return Object.defineProperty(e,r,{value:t[r],enumerable:!0})},{})}function isPromise(e){return e&&"function"==typeof e.then&&"function"==typeof e.catch}worker.methods={},worker.methods.run=function run(fn,args){var f=eval("("+fn+")");return f.apply(f,args)},worker.methods.methods=function(){return Object.keys(worker.methods)},worker.on("message",function(r){try{var e=worker.methods[r.method];if(!e)throw new Error('Unknown method "'+r.method+'"');var t=e.apply(e,r.params);isPromise(t)?t.then(function(e){worker.send({id:r.id,result:e,error:null})}).catch(function(e){worker.send({id:r.id,result:null,error:convertError(e)})}):worker.send({id:r.id,result:t,error:null})}catch(e){worker.send({id:r.id,result:null,error:convertError(e)})}}),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send("ready")},exports.add=worker.register}],e={},g.m=d,g.c=e,g.d=function(e,r,t){g.o(e,r)||Object.defineProperty(e,r,{enumerable:!0,get:t})},g.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},g.t=function(r,e){if(1&e&&(r=g(r)),8&e)return r;if(4&e&&"object"==typeof r&&r&&r.__esModule)return r;var t=Object.create(null);if(g.r(t),Object.defineProperty(t,"default",{enumerable:!0,value:r}),2&e&&"string"!=typeof r)for(var o in r)g.d(t,o,function(e){return r[e]}.bind(null,o));return t},g.n=function(e){var r=e&&e.__esModule?function(){return e.default}:function(){return e};return g.d(r,"a",r),r},g.o=function(e,r){return Object.prototype.hasOwnProperty.call(e,r)},g.p="",g(g.s=3);function g(r){if(e[r])return e[r].exports;var t=e[r]={i:r,l:!1,exports:{}};return d[r].call(t.exports,t,t.exports,g),t.l=!0,t.exports}var d,e});
+!function(e,r){"object"==typeof exports&&"object"==typeof module?module.exports=r():"function"==typeof define&&define.amd?define("workerpool",[],r):"object"==typeof exports?exports.workerpool=r():e.workerpool=r()}("undefined"!=typeof self?self:this,function(){return d=[function(e,r,t){function o(e){return void 0!==e&&null!=e.versions&&null!=e.versions.node}var n=t(2);e.exports.isNode=o,e.exports.platform="undefined"!=typeof process&&o(process)?"node":"browser";var i=function(e){try{return n(e)}catch(e){return null}}("worker_threads");e.exports.isMainThread="node"===e.exports.platform?(!i||i.isMainThread)&&!process.connected:"undefined"!=typeof Window,e.exports.cpus="browser"===e.exports.platform?self.navigator.hardwareConcurrency:n("os").cpus().length},function(e,r,t){"use strict";function a(e,t){var o=this;if(!(this instanceof a))throw new SyntaxError("Constructor must be called with the new operator");if("function"!=typeof e)throw new SyntaxError("Function parameter handler(resolve, reject) missing");var n=[],i=[];this.resolved=!1,this.rejected=!1,this.pending=!0;var s=function(e,r){n.push(e),i.push(r)};this.then=function(n,i){return new a(function(e,r){var t=n?c(n,e,r):e,o=i?c(i,e,r):r;s(t,o)},o)};var r=function(t){return o.resolved=!0,o.rejected=!1,o.pending=!1,n.forEach(function(e){e(t)}),s=function(e,r){e(t)},r=u=function(){},o},u=function(t){return o.resolved=!1,o.rejected=!0,o.pending=!1,i.forEach(function(e){e(t)}),s=function(e,r){r(t)},r=u=function(){},o};this.cancel=function(){return t?t.cancel():u(new f),o},this.timeout=function(e){if(t)t.timeout(e);else{var r=setTimeout(function(){u(new p("Promise timed out after "+e+" ms"))},e);o.always(function(){clearTimeout(r)})}return o},e(function(e){r(e)},function(e){u(e)})}function c(t,o,n){return function(e){try{var r=t(e);r&&"function"==typeof r.then&&"function"==typeof r.catch?r.then(o,n):o(r)}catch(e){n(e)}}}function f(e){this.message=e||"promise cancelled",this.stack=(new Error).stack}function p(e){this.message=e||"timeout exceeded",this.stack=(new Error).stack}a.prototype.catch=function(e){return this.then(null,e)},a.prototype.always=function(e){return this.then(e,e)},a.all=function(e){return new a(function(t,o){var n=e.length,i=[];n?e.forEach(function(e,r){e.then(function(e){i[r]=e,0==--n&&t(i)},function(e){n=0,o(e)})}):t(i)})},a.defer=function(){var t={};return t.promise=new a(function(e,r){t.resolve=e,t.reject=r}),t},(f.prototype=new Error).constructor=Error,f.prototype.name="CancellationError",a.CancellationError=f,(p.prototype=new Error).constructor=Error,p.prototype.name="TimeoutError",a.TimeoutError=p,e.exports=a},function(module,exports){var requireFoolWebpack=eval("typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \" + module + \" not found.') }");module.exports=requireFoolWebpack},function(e,r,t){var o=t(0);r.pool=function(e,r){return new(t(4))(e,r)},r.worker=function(e){var r=t(8);r.add(e)},r.Promise=t(1),r.platform=o.platform,r.isMainThread=o.isMainThread,r.cpus=o.cpus},function(e,r,t){var s=t(1),o=t(5),n=t(0),i=new(t(7));function u(e,r){"string"==typeof e?this.script=e||null:(this.script=null,r=e),this.workers=[],this.tasks=[],(r=r||{}).nodeWorker&&console.warn('WARNING: Option "nodeWorker" is deprecated since workerpool@5.0.0. Please use "workerType" instead.'),this.forkArgs=r.forkArgs||[],this.forkOpts=r.forkOpts||{},this.debugPortStart=r.debugPortStart||43210,this.nodeWorker=r.nodeWorker,this.workerType=r.workerType||r.nodeWorker||"auto",this.maxQueueSize=r.maxQueueSize||1/0,r&&"maxWorkers"in r?(function(e){if(!a(e)||!c(e)||e<1)throw new TypeError("Option maxWorkers must be an integer number >= 1")}(r.maxWorkers),this.maxWorkers=r.maxWorkers):this.maxWorkers=Math.max((n.cpus||4)-1,1),r&&"minWorkers"in r&&("max"===r.minWorkers?this.minWorkers=this.maxWorkers:(function(e){if(!a(e)||!c(e)||e<0)throw new TypeError("Option minWorkers must be an integer number >= 0")}(r.minWorkers),this.minWorkers=r.minWorkers,this.maxWorkers=Math.max(this.minWorkers,this.maxWorkers)),this._ensureMinWorkers()),this._boundNext=this._next.bind(this),"thread"===this.workerType&&o.ensureWorkerThreads()}function a(e){return"number"==typeof e}function c(e){return Math.round(e)==e}u.prototype.exec=function(e,r){if(r&&!Array.isArray(r))throw new TypeError('Array expected as argument "params"');if("string"==typeof e){var t=s.defer();if(this.tasks.length>=this.maxQueueSize)throw new Error("Max queue size of "+this.maxQueueSize+" reached");var o=this.tasks,n={method:e,params:r,resolver:t,timeout:null};o.push(n);var i=t.promise.timeout;return t.promise.timeout=function(e){return-1!==o.indexOf(n)?(n.timeout=e,t.promise):i.call(t.promise,e)},this._next(),t.promise}if("function"==typeof e)return this.exec("run",[String(e),r]);throw new TypeError('Function or string expected as argument "method"')},u.prototype.proxy=function(){if(0<arguments.length)throw new Error("No arguments expected");var t=this;return this.exec("methods").then(function(e){var r={};return e.forEach(function(e){r[e]=function(){return t.exec(e,Array.prototype.slice.call(arguments))}}),r})},u.prototype._next=function(){if(0<this.tasks.length){var e=this._getWorker();if(e){var r=this,t=this.tasks.shift();if(t.resolver.promise.pending){var o=e.exec(t.method,t.params,t.resolver).then(r._boundNext).catch(function(){e.terminated&&(r._removeWorker(e),r._ensureMinWorkers()),r._next()});"number"==typeof t.timeout&&o.timeout(t.timeout)}else r._next()}}},u.prototype._getWorker=function(){for(var e=this.workers,r=0;r<e.length;r++){var t=e[r];if(!1===t.busy())return t}return e.length<this.maxWorkers?(t=this._createWorkerHandler(),e.push(t),t):null},u.prototype._removeWorker=function(e){i.releasePort(e.debugPort),e.terminate(),this._removeWorkerFromList(e)},u.prototype._removeWorkerFromList=function(e){var r=this.workers.indexOf(e);-1!==r&&this.workers.splice(r,1)},u.prototype.terminate=function(t,o){this.tasks.forEach(function(e){e.resolver.reject(new Error("Pool terminated"))}),this.tasks.length=0;var n=function(e){this._removeWorkerFromList(e)}.bind(this),i=[];return this.workers.slice().forEach(function(e){var r=e.terminateAndNotify(t,o).then(n);i.push(r)}),s.all(i)},u.prototype.clear=function(e){console.warn("Pool.clear() is deprecated. Use Pool.terminate() instead."),this.terminate(e)},u.prototype.stats=function(){var e=this.workers.length,r=this.workers.filter(function(e){return e.busy()}).length;return{totalWorkers:e,busyWorkers:r,idleWorkers:e-r,pendingTasks:this.tasks.length,activeTasks:r}},u.prototype._ensureMinWorkers=function(){if(this.minWorkers)for(var e=this.workers.length;e<this.minWorkers;e++)this.workers.push(this._createWorkerHandler())},u.prototype._createWorkerHandler=function(){return new o(this.script,{forkArgs:this.forkArgs,forkOpts:this.forkOpts,debugPort:i.nextAvailableStartingAt(this.debugPortStart),workerType:this.workerType})},e.exports=u},function(e,r,s){"use strict";var u=s(1),a=s(0),c=s(2);function f(){var e=d();if(!e)throw new Error("WorkerPool: workerType = 'thread' is not supported, Node >= 11.7.0 required");return e}function p(){if("function"!=typeof Worker&&("object"!=typeof Worker||"function"!=typeof Worker.prototype.constructor))throw new Error("WorkerPool: Web Workers not supported")}function d(){try{return c("worker_threads")}catch(e){if("object"==typeof e&&null!==e&&"MODULE_NOT_FOUND"===e.code)return null;throw e}}function h(e,r){var t=new r(e);return t.isBrowserWorker=!0,t.on=function(e,r){this.addEventListener(e,function(e){r(e.data)})},t.send=function(e){this.postMessage(e)},t}function l(e,r){var t=new r.Worker(e,{stdout:!1,stderr:!1});return t.isWorkerThread=!0,t.send=function(e){this.postMessage(e)},t.kill=function(){this.terminate()},t.disconnect=function(){this.terminate()},t}function k(e,r,t){var o=t.fork(e,r.forkArgs,r.forkOpts);return o.isChildProcess=!0,o}function m(e){e=e||{};var r=process.execArgv.join(" "),t=-1!==r.indexOf("--inspect"),o=-1!==r.indexOf("--debug-brk"),n=[];return t&&(n.push("--inspect="+e.debugPort),o&&n.push("--debug-brk")),process.execArgv.forEach(function(e){-1<e.indexOf("--max-old-space-size")&&n.push(e)}),Object.assign({},e,{forkArgs:e.forkArgs,forkOpts:Object.assign({},e.forkOpts,{execArgv:(e.forkOpts&&e.forkOpts.execArgv||[]).concat(n)})})}function t(e,r){var o=this,t=r||{};function n(e){for(var r in o.terminated=!0,o.terminating&&o.terminationHandler&&o.terminationHandler(o),o.terminating=!1,o.processing)void 0!==o.processing[r]&&o.processing[r].resolver.reject(e);o.processing=Object.create(null)}this.script=e||function(){if("browser"!==a.platform)return __dirname+"/worker.js";if("undefined"==typeof Blob)throw new Error("Blob not supported by the browser");if(!window.URL||"function"!=typeof window.URL.createObjectURL)throw new Error("URL.createObjectURL not supported by the browser");var e=new Blob([s(6)],{type:"text/javascript"});return window.URL.createObjectURL(e)}(),this.worker=function(e,r){if("web"===r.workerType)return p(),h(e,Worker);if("thread"===r.workerType)return l(e,t=f());if("process"!==r.workerType&&r.workerType){if("browser"===a.platform)return p(),h(e,Worker);var t=d();return t?l(e,t):k(e,m(r),c("child_process"))}return k(e,m(r),c("child_process"))}(this.script,t),this.debugPort=t.debugPort,e||(this.worker.ready=!0),this.requestQueue=[],this.worker.on("message",function(e){if("string"==typeof e&&"ready"===e)o.worker.ready=!0,o.requestQueue.forEach(o.worker.send.bind(o.worker)),o.requestQueue=[];else{var r=e.id,t=o.processing[r];void 0!==t&&(delete o.processing[r],!0===o.terminating&&o.terminate(),e.error?t.resolver.reject(function(e){for(var r=new Error(""),t=Object.keys(e),o=0;o<t.length;o++)r[t[o]]=e[t[o]];return r}(e.error)):t.resolver.resolve(e.result))}});var i=this.worker;this.worker.on("error",n),this.worker.on("exit",function(e,r){var t="Workerpool Worker terminated Unexpectedly\n";t+="    exitCode: `"+e+"`\n",t+="    signalCode: `"+r+"`\n",t+="    workerpool.script: `"+o.script+"`\n",t+="    spawnArgs: `"+i.spawnargs+"`\n",t+="    spawnfile: `"+i.spawnfile+"`\n",t+="    stdout: `"+i.stdout+"`\n",t+="    stderr: `"+i.stderr+"`\n",n(new Error(t))}),this.processing=Object.create(null),this.terminating=!1,this.terminated=!1,this.terminationHandler=null,this.lastId=0}t.prototype.methods=function(){return this.exec("methods")},t.prototype.exec=function(e,r,t){t=t||u.defer();var o=++this.lastId;this.processing[o]={id:o,resolver:t};var n={id:o,method:e,params:r};this.terminated?t.reject(new Error("Worker is terminated")):this.worker.ready?this.worker.send(n):this.requestQueue.push(n);var i=this;return t.promise.catch(function(e){if(!(e instanceof u.CancellationError||e instanceof u.TimeoutError))throw e;delete i.processing[o],i.terminate(!0)}),t.promise},t.prototype.busy=function(){return 0<Object.keys(this.processing).length},t.prototype.terminate=function(e,r){if(e){for(var t in this.processing)void 0!==this.processing[t]&&this.processing[t].resolver.reject(new Error("Worker terminated"));this.processing=Object.create(null)}if("function"==typeof r&&(this.terminationHandler=r),this.busy())this.terminating=!0;else{if(this.worker){if("function"==typeof this.worker.kill)this.worker.kill();else{if("function"!=typeof this.worker.terminate)throw new Error("Failed to terminate worker");this.worker.terminate()}this.worker=null}this.terminating=!1,this.terminated=!0,this.terminationHandler&&this.terminationHandler(this)}},t.prototype.terminateAndNotify=function(e,r){var t=u.defer();return r&&(t.promise.timeout=r),this.terminate(e,function(e){t.resolve(e)}),t.promise},e.exports=t,e.exports._tryRequireWorkerThreads=d,e.exports._setupProcessWorker=k,e.exports._setupBrowserWorker=h,e.exports._setupWorkerThreadWorker=l,e.exports.ensureWorkerThreads=f},function(e,r){e.exports='!function(o){var n={};function t(e){if(n[e])return n[e].exports;var r=n[e]={i:e,l:!1,exports:{}};return o[e].call(r.exports,r,r.exports,t),r.l=!0,r.exports}t.m=o,t.c=n,t.d=function(e,r,o){t.o(e,r)||Object.defineProperty(e,r,{enumerable:!0,get:o})},t.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},t.t=function(r,e){if(1&e&&(r=t(r)),8&e)return r;if(4&e&&"object"==typeof r&&r&&r.__esModule)return r;var o=Object.create(null);if(t.r(o),Object.defineProperty(o,"default",{enumerable:!0,value:r}),2&e&&"string"!=typeof r)for(var n in r)t.d(o,n,function(e){return r[e]}.bind(null,n));return o},t.n=function(e){var r=e&&e.__esModule?function(){return e.default}:function(){return e};return t.d(r,"a",r),r},t.o=function(e,r){return Object.prototype.hasOwnProperty.call(e,r)},t.p="",t(t.s=0)}([function(module,exports,__webpack_require__){var requireFoolWebpack=eval("typeof require !== \'undefined\' ? require : function (module) { throw new Error(\'Module \\" + module + \\" not found.\') }"),worker={};if("undefined"!=typeof self&&"function"==typeof postMessage&&"function"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,function(e){r(e.data)})},worker.send=function(e){postMessage(e)};else{if("undefined"==typeof process)throw new Error("Script must be executed as a worker");var WorkerThreads;try{WorkerThreads=requireFoolWebpack("worker_threads")}catch(e){if("object"!=typeof e||null===e||"MODULE_NOT_FOUND"!=e.code)throw e}if(WorkerThreads&&null!==WorkerThreads.parentPort){var parentPort=WorkerThreads.parentPort;worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)}else worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on("disconnect",function(){process.exit(1)})}function convertError(o){return Object.getOwnPropertyNames(o).reduce(function(e,r){return Object.defineProperty(e,r,{value:o[r],enumerable:!0})},{})}function isPromise(e){return e&&"function"==typeof e.then&&"function"==typeof e.catch}worker.methods={},worker.methods.run=function run(fn,args){var f=eval("("+fn+")");return f.apply(f,args)},worker.methods.methods=function(){return Object.keys(worker.methods)},worker.on("message",function(r){try{var e=worker.methods[r.method];if(!e)throw new Error(\'Unknown method "\'+r.method+\'"\');var o=e.apply(e,r.params);isPromise(o)?o.then(function(e){worker.send({id:r.id,result:e,error:null})}).catch(function(e){worker.send({id:r.id,result:null,error:convertError(e)})}):worker.send({id:r.id,result:o,error:null})}catch(e){worker.send({id:r.id,result:null,error:convertError(e)})}}),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send("ready")},exports.add=worker.register}]);'},function(e,r,t){"use strict";function o(){this.ports=Object.create(null),this.length=0}(e.exports=o).prototype.nextAvailableStartingAt=function(e){for(;!0===this.ports[e];)e++;if(65535<=e)throw new Error("WorkerPool debug port limit reached: "+e+">= 65535");return this.ports[e]=!0,this.length++,e},o.prototype.releasePort=function(e){delete this.ports[e],this.length--}},function(module,exports,__webpack_require__){var requireFoolWebpack=eval("typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \" + module + \" not found.') }"),worker={};if("undefined"!=typeof self&&"function"==typeof postMessage&&"function"==typeof addEventListener)worker.on=function(e,r){addEventListener(e,function(e){r(e.data)})},worker.send=function(e){postMessage(e)};else{if("undefined"==typeof process)throw new Error("Script must be executed as a worker");var WorkerThreads;try{WorkerThreads=requireFoolWebpack("worker_threads")}catch(e){if("object"!=typeof e||null===e||"MODULE_NOT_FOUND"!=e.code)throw e}if(WorkerThreads&&null!==WorkerThreads.parentPort){var parentPort=WorkerThreads.parentPort;worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)}else worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on("disconnect",function(){process.exit(1)})}function convertError(t){return Object.getOwnPropertyNames(t).reduce(function(e,r){return Object.defineProperty(e,r,{value:t[r],enumerable:!0})},{})}function isPromise(e){return e&&"function"==typeof e.then&&"function"==typeof e.catch}worker.methods={},worker.methods.run=function run(fn,args){var f=eval("("+fn+")");return f.apply(f,args)},worker.methods.methods=function(){return Object.keys(worker.methods)},worker.on("message",function(r){try{var e=worker.methods[r.method];if(!e)throw new Error('Unknown method "'+r.method+'"');var t=e.apply(e,r.params);isPromise(t)?t.then(function(e){worker.send({id:r.id,result:e,error:null})}).catch(function(e){worker.send({id:r.id,result:null,error:convertError(e)})}):worker.send({id:r.id,result:t,error:null})}catch(e){worker.send({id:r.id,result:null,error:convertError(e)})}}),worker.register=function(e){if(e)for(var r in e)e.hasOwnProperty(r)&&(worker.methods[r]=e[r]);worker.send("ready")},exports.add=worker.register}],e={},g.m=d,g.c=e,g.d=function(e,r,t){g.o(e,r)||Object.defineProperty(e,r,{enumerable:!0,get:t})},g.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},g.t=function(r,e){if(1&e&&(r=g(r)),8&e)return r;if(4&e&&"object"==typeof r&&r&&r.__esModule)return r;var t=Object.create(null);if(g.r(t),Object.defineProperty(t,"default",{enumerable:!0,value:r}),2&e&&"string"!=typeof r)for(var o in r)g.d(t,o,function(e){return r[e]}.bind(null,o));return t},g.n=function(e){var r=e&&e.__esModule?function(){return e.default}:function(){return e};return g.d(r,"a",r),r},g.o=function(e,r){return Object.prototype.hasOwnProperty.call(e,r)},g.p="",g(g.s=3);function g(r){if(e[r])return e[r].exports;var t=e[r]={i:r,l:!1,exports:{}};return d[r].call(t.exports,t,t.exports,g),t.l=!0,t.exports}var d,e});
 //# sourceMappingURL=workerpool.map

HISTORY.md

@@ -5,2 +5,8 @@ # workerpool history
 
+## 2019-12-31, version 5.0.4
+
+- Fixed #121: `isMainThread` not working when using `worker_threads`.
+- Drop official support for node.js 8 (end of life).
+
+
 ## 2019-12-23, version 5.0.3
@@ -7,0 +13,0 @@

package.json

 {
   "name": "workerpool",
   "license": "Apache-2.0",
-  "version": "5.0.3",
+  "version": "5.0.4",
   "description": "Offload tasks to a pool of workers on node.js and in the browser",
@@ -44,4 +44,4 @@ "homepage": "https://github.com/josdejong/workerpool",
     "mocha": "6.2.2",
-    "uglify-js": "3.7.2",
-    "webpack": "4.41.4",
+    "uglify-js": "3.7.3",
+    "webpack": "4.41.5",
     "handlebars": "4.5.3"
@@ -48,0 +48,0 @@ },

src/environment.js

@@ -5,7 +5,7 @@ var requireFoolWebpack = require('./requireFoolWebpack');
 var isNode = function (nodeProcess) {
-    return (
-        typeof nodeProcess !== 'undefined' &&
-        nodeProcess.versions != null &&
-        nodeProcess.versions.node != null
-    );
+  return (
+    typeof nodeProcess !== 'undefined' &&
+    nodeProcess.versions != null &&
+    nodeProcess.versions.node != null
+  );
 }
@@ -16,13 +16,23 @@ module.exports.isNode = isNode
 module.exports.platform = typeof process !== 'undefined' && isNode(process)
-    ? 'node'
-    : 'browser';
+  ? 'node'
+  : 'browser';
 
 // determines whether the code is running in main thread or not
+// note that in node.js we have to check both worker_thread and child_process
+var worker_threads = tryRequireFoolWebpack('worker_threads');
 module.exports.isMainThread = module.exports.platform === 'node'
-    ? !process.connected
-    : typeof Window !== 'undefined';
+  ? ((!worker_threads || worker_threads.isMainThread) && !process.connected)
+  : typeof Window !== 'undefined';
 
 // determines the number of cpus available
 module.exports.cpus = module.exports.platform === 'browser'
-    ? self.navigator.hardwareConcurrency
-    : requireFoolWebpack('os').cpus().length;
+  ? self.navigator.hardwareConcurrency
+  : requireFoolWebpack('os').cpus().length;
+
+function tryRequireFoolWebpack (module) {
+  try {
+    return requireFoolWebpack(module);
+  } catch(err) {
+    return null
+  }
+}

New alerts

Potential vulnerability

Supply chain risk

Initial human review suggests the presence of a vulnerability in this package. It is pending further analysis and confirmation.

Found 1 instance in 1 package

Uses eval

Supply chain risk

Package uses dynamic code execution (e.g., eval()), which is a dangerous practice. This can prevent the code from running in certain environments and increases the risk that the code may contain exploits or malicious behavior.

Found 1 instance in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

AI-detected potential code anomaly

Supply chain risk

AI has identified unusual behaviors that may pose a security risk.

Found 1 instance in 1 package

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Fixed alerts

Potential vulnerability

Supply chain risk

Initial human review suggests the presence of a vulnerability in this package. It is pending further analysis and confirmation.

Found 1 instance in 1 package

Uses eval

Supply chain risk

Package uses dynamic code execution (e.g., eval()), which is a dangerous practice. This can prevent the code from running in certain environments and increases the risk that the code may contain exploits or malicious behavior.

Found 1 instance in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

AI-detected potential code anomaly

Supply chain risk

AI has identified unusual behaviors that may pose a security risk.

Found 2 instances in 1 package

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

316801

0.32%

Lines of code

6848

0.26%

Number of low supply chain risk alerts

11

-8.33%

No dependency changes