async
Advanced tools
Comparing version 3.2.4 to 3.2.5
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -116,5 +116,5 @@ | ||
| function every(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)(_eachOf2.default, coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)(_eachOf2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(every, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -43,5 +43,5 @@ | ||
| function everyLimit(coll, limit, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(everyLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -42,5 +42,5 @@ | ||
| function everySeries(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(everySeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -119,5 +119,5 @@ | ||
| function some(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(Boolean, res => res)(_eachOf2.default, coll, iteratee, callback); | ||
| return (0, _createTester2.default)(Boolean, res => res)(_eachOf2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(some, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -44,5 +44,5 @@ | ||
| function someLimit(coll, limit, iteratee, callback) { | ||
| return (0, _createTester2.default)(Boolean, res => res)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| return (0, _createTester2.default)(Boolean, res => res)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(someLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -43,5 +43,5 @@ | ||
| function someSeries(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(Boolean, res => res)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| return (0, _createTester2.default)(Boolean, res => res)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(someSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
50
apply.js
| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
| exports.default = function (fn, ...args) { | ||
| return (...callArgs) => fn(...args, ...callArgs); | ||
| return (...callArgs) => fn(...args, ...callArgs); | ||
| }; | ||
| module.exports = exports["default"]; /** | ||
| * Creates a continuation function with some arguments already applied. | ||
| * | ||
| * Useful as a shorthand when combined with other control flow functions. Any | ||
| * arguments passed to the returned function are added to the arguments | ||
| * originally passed to apply. | ||
| * | ||
| * @name apply | ||
| * @static | ||
| * @memberOf module:Utils | ||
| * @method | ||
| * @category Util | ||
| * @param {Function} fn - The function you want to eventually apply all | ||
| * arguments to. Invokes with (arguments...). | ||
| * @param {...*} arguments... - Any number of arguments to automatically apply | ||
| * when the continuation is called. | ||
| * @returns {Function} the partially-applied function | ||
| * @example | ||
| * | ||
| * // using apply | ||
| * async.parallel([ | ||
| * async.apply(fs.writeFile, 'testfile1', 'test1'), | ||
| * async.apply(fs.writeFile, 'testfile2', 'test2') | ||
| * ]); | ||
| * | ||
| * | ||
| * // the same process without using apply | ||
| * async.parallel([ | ||
| * function(callback) { | ||
| * fs.writeFile('testfile1', 'test1', callback); | ||
| * }, | ||
| * function(callback) { | ||
| * fs.writeFile('testfile2', 'test2', callback); | ||
| * } | ||
| * ]); | ||
| * | ||
| * // It's possible to pass any number of additional arguments when calling the | ||
| * // continuation: | ||
| * | ||
| * node> var fn = async.apply(sys.puts, 'one'); | ||
| * node> fn('two', 'three'); | ||
| * one | ||
| * two | ||
| * three | ||
| */ | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -57,2 +57,2 @@ | ||
| exports.default = (0, _applyEach2.default)(_map2.default); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -37,2 +37,2 @@ | ||
| exports.default = (0, _applyEach2.default)(_mapSeries2.default); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -105,3 +105,3 @@ 'use strict'; | ||
| }, err => { | ||
| invokeCallback(callback, err && err.message ? err : new Error(err)); | ||
| invokeCallback(callback, err && (err instanceof Error || err.message) ? err : new Error(err)); | ||
| }); | ||
@@ -119,2 +119,2 @@ } | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -333,2 +333,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -182,2 +182,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -61,4 +61,4 @@ exports.default = cargo; | ||
| function cargo(worker, payload) { | ||
| return (0, _queue2.default)(worker, 1, payload); | ||
| return (0, _queue2.default)(worker, 1, payload); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -69,4 +69,4 @@ exports.default = cargo; | ||
| function cargo(worker, concurrency, payload) { | ||
| return (0, _queue2.default)(worker, concurrency, payload); | ||
| return (0, _queue2.default)(worker, concurrency, payload); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -53,4 +53,4 @@ exports.default = compose; | ||
| function compose(...args) { | ||
| return (0, _seq2.default)(...args.reverse()); | ||
| return (0, _seq2.default)(...args.reverse()); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -112,5 +112,5 @@ | ||
| function concat(coll, iteratee, callback) { | ||
| return (0, _concatLimit2.default)(coll, Infinity, iteratee, callback); | ||
| return (0, _concatLimit2.default)(coll, Infinity, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(concat, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -60,2 +60,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(concatLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -38,5 +38,5 @@ | ||
| function concatSeries(coll, iteratee, callback) { | ||
| return (0, _concatLimit2.default)(coll, 1, iteratee, callback); | ||
| return (0, _concatLimit2.default)(coll, 1, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(concatSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -14,43 +14,2 @@ "use strict"; | ||
| module.exports = exports["default"]; /** | ||
| * Returns a function that when called, calls-back with the values provided. | ||
| * Useful as the first function in a [`waterfall`]{@link module:ControlFlow.waterfall}, or for plugging values in to | ||
| * [`auto`]{@link module:ControlFlow.auto}. | ||
| * | ||
| * @name constant | ||
| * @static | ||
| * @memberOf module:Utils | ||
| * @method | ||
| * @category Util | ||
| * @param {...*} arguments... - Any number of arguments to automatically invoke | ||
| * callback with. | ||
| * @returns {AsyncFunction} Returns a function that when invoked, automatically | ||
| * invokes the callback with the previous given arguments. | ||
| * @example | ||
| * | ||
| * async.waterfall([ | ||
| * async.constant(42), | ||
| * function (value, next) { | ||
| * // value === 42 | ||
| * }, | ||
| * //... | ||
| * ], callback); | ||
| * | ||
| * async.waterfall([ | ||
| * async.constant(filename, "utf8"), | ||
| * fs.readFile, | ||
| * function (fileData, next) { | ||
| * //... | ||
| * } | ||
| * //... | ||
| * ], callback); | ||
| * | ||
| * async.auto({ | ||
| * hostname: async.constant("https://server.net/"), | ||
| * port: findFreePort, | ||
| * launchServer: ["hostname", "port", function (options, cb) { | ||
| * startServer(options, cb); | ||
| * }], | ||
| * //... | ||
| * }, callback); | ||
| */ | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -93,5 +93,5 @@ | ||
| function detect(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)(_eachOf2.default, coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)(_eachOf2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(detect, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -45,5 +45,5 @@ | ||
| function detectLimit(coll, limit, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(detectLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -43,6 +43,6 @@ | ||
| function detectSeries(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)((0, _eachOfLimit2.default)(1), coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)((0, _eachOfLimit2.default)(1), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(detectSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -43,2 +43,2 @@ | ||
| exports.default = (0, _consoleFunc2.default)('dir'); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -1,1 +0,1 @@ | ||
| (function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports):"function"==typeof define&&define.amd?define(["exports"],t):t(e.async={})})(this,function(e){'use strict';function t(e,...t){return(...n)=>e(...t,...n)}function n(e){return function(...t){var n=t.pop();return e.call(this,t,n)}}function a(e){setTimeout(e,0)}function i(e){return(t,...n)=>e(()=>t(...n))}function r(e){return u(e)?function(...t){const n=t.pop(),a=e.apply(this,t);return s(a,n)}:n(function(t,n){var a;try{a=e.apply(this,t)}catch(t){return n(t)}return a&&"function"==typeof a.then?s(a,n):void n(null,a)})}function s(e,t){return e.then(e=>{l(t,null,e)},e=>{l(t,e&&e.message?e:new Error(e))})}function l(e,t,n){try{e(t,n)}catch(e){_e(t=>{throw t},e)}}function u(e){return"AsyncFunction"===e[Symbol.toStringTag]}function d(e){return"AsyncGenerator"===e[Symbol.toStringTag]}function p(e){return"function"==typeof e[Symbol.asyncIterator]}function c(e){if("function"!=typeof e)throw new Error("expected a function");return u(e)?r(e):e}function o(e,t=e.length){if(!t)throw new Error("arity is undefined");return function(...n){return"function"==typeof n[t-1]?e.apply(this,n):new Promise((a,i)=>{n[t-1]=(e,...t)=>e?i(e):void a(1<t.length?t:t[0]),e.apply(this,n)})}}function h(e){return function(t,...n){const a=o(function(a){var i=this;return e(t,(e,t)=>{c(e).apply(i,n.concat(t))},a)});return a}}function f(e,t,n,a){t=t||[];var i=[],r=0,s=c(n);return e(t,(e,t,n)=>{var a=r++;s(e,(e,t)=>{i[a]=t,n(e)})},e=>{a(e,i)})}function y(e){return e&&"number"==typeof e.length&&0<=e.length&&0==e.length%1}function m(e){function t(...t){if(null!==e){var n=e;e=null,n.apply(this,t)}}return Object.assign(t,e),t}function g(e){return e[Symbol.iterator]&&e[Symbol.iterator]()}function k(e){var t=-1,n=e.length;return function(){return++t<n?{value:e[t],key:t}:null}}function v(e){var t=-1;return function(){var n=e.next();return n.done?null:(t++,{value:n.value,key:t})}}function S(e){var t=e?Object.keys(e):[],n=-1,a=t.length;return function i(){var r=t[++n];return"__proto__"===r?i():n<a?{value:e[r],key:r}:null}}function x(e){if(y(e))return k(e);var t=g(e);return t?v(t):S(e)}function L(e){return function(...t){if(null===e)throw new Error("Callback was already called.");var n=e;e=null,n.apply(this,t)}}function E(e,t,n,a){function i(){p>=t||d||l||(d=!0,e.next().then(({value:e,done:t})=>{if(!(u||l))return d=!1,t?(l=!0,void(0>=p&&a(null))):void(p++,n(e,c,r),c++,i())}).catch(s))}function r(e,t){return p-=1,u?void 0:e?s(e):!1===e?(l=!0,void(u=!0)):t===be||l&&0>=p?(l=!0,a(null)):void i()}function s(e){u||(d=!1,l=!0,a(e))}let l=!1,u=!1,d=!1,p=0,c=0;i()}function O(e,t,n){function a(e,t){!1===e&&(l=!0);!0===l||(e?n(e):(++r===s||t===be)&&n(null))}n=m(n);var i=0,r=0,{length:s}=e,l=!1;for(0===s&&n(null);i<s;i++)t(e[i],i,L(a))}function _(e,t,n){return Ie(e,1/0,t,n)}function b(){function e(e,...a){return e?n(e):void t(1<a.length?a:a[0])}let t,n;return e[Ce]=new Promise((e,a)=>{t=e,n=a}),e}function A(e,t,n){function a(e,t){g.push(()=>l(e,t))}function i(){if(!h){if(0===g.length&&0===o)return n(null,p);for(;g.length&&o<t;){var e=g.shift();e()}}}function r(e,t){var n=y[e];n||(n=y[e]=[]),n.push(t)}function s(e){var t=y[e]||[];t.forEach(e=>e()),i()}function l(e,t){if(!f){var a=L((t,...a)=>{if(o--,!1===t)return void(h=!0);if(2>a.length&&([a]=a),t){var i={};if(Object.keys(p).forEach(e=>{i[e]=p[e]}),i[e]=a,f=!0,y=Object.create(null),h)return;n(t,i)}else p[e]=a,s(e)});o++;var i=c(t[t.length-1]);1<t.length?i(p,a):i(a)}}function u(t){var n=[];return Object.keys(e).forEach(a=>{const i=e[a];Array.isArray(i)&&0<=i.indexOf(t)&&n.push(a)}),n}"number"!=typeof t&&(n=t,t=null),n=m(n||b());var d=Object.keys(e).length;if(!d)return n(null);t||(t=d);var p={},o=0,h=!1,f=!1,y=Object.create(null),g=[],k=[],v={};return Object.keys(e).forEach(t=>{var n=e[t];if(!Array.isArray(n))return a(t,[n]),void k.push(t);var i=n.slice(0,n.length-1),s=i.length;return 0===s?(a(t,n),void k.push(t)):void(v[t]=s,i.forEach(l=>{if(!e[l])throw new Error("async.auto task `"+t+"` has a non-existent dependency `"+l+"` in "+i.join(", "));r(l,()=>{s--,0===s&&a(t,n)})}))}),function(){for(var e,t=0;k.length;)e=k.pop(),t++,u(e).forEach(e=>{0==--v[e]&&k.push(e)});if(t!==d)throw new Error("async.auto cannot execute tasks due to a recursive dependency")}(),i(),n[Ce]}function I(e){let t="",n=0,a=e.indexOf("*/");for(;n<e.length;)if("/"===e[n]&&"/"===e[n+1]){let t=e.indexOf("\n",n);n=-1===t?e.length:t}else if(-1!==a&&"/"===e[n]&&"*"===e[n+1]){let i=e.indexOf("*/",n);-1===i?(t+=e[n],n++):(n=i+2,a=e.indexOf("*/",n))}else t+=e[n],n++;return t}function M(e){const t=I(e.toString());let n=t.match(Pe);if(n||(n=t.match(Re)),!n)throw new Error("could not parse args in autoInject\nSource:\n"+t);let[,a]=n;return a.replace(/\s/g,"").split(ze).map(e=>e.replace(Ne,"").trim())}function j(e,t){var n={};return Object.keys(e).forEach(t=>{function a(e,t){var n=i.map(t=>e[t]);n.push(t),c(r)(...n)}var i,r=e[t],s=u(r),l=!s&&1===r.length||s&&0===r.length;if(Array.isArray(r))i=[...r],r=i.pop(),n[t]=i.concat(0<i.length?a:r);else if(l)n[t]=r;else{if(i=M(r),0===r.length&&!s&&0===i.length)throw new Error("autoInject task functions require explicit parameters.");s||i.pop(),n[t]=i.concat(a)}}),A(n,t)}function w(e,t){e.length=1,e.head=e.tail=t}function B(e,t,n){function a(e,t){f[e].push(t)}function i(e,t){const n=(...a)=>{r(e,n),t(...a)};f[e].push(n)}function r(e,t){return e?t?void(f[e]=f[e].filter(e=>e!==t)):f[e]=[]:Object.keys(f).forEach(e=>f[e]=[])}function s(e,...t){f[e].forEach(e=>e(...t))}function l(e,t,n,a){function i(e,...t){return e?n?s(e):r():1>=t.length?r(t[0]):void r(t)}if(null!=a&&"function"!=typeof a)throw new Error("task callback must be a function");k.started=!0;var r,s,l=k._createTaskItem(e,n?i:a||i);if(t?k._tasks.unshift(l):k._tasks.push(l),y||(y=!0,_e(()=>{y=!1,k.process()})),n||!a)return new Promise((e,t)=>{r=e,s=t})}function u(e){return function(t,...n){o-=1;for(var a=0,r=e.length;a<r;a++){var l=e[a],u=h.indexOf(l);0===u?h.shift():0<u&&h.splice(u,1),l.callback(t,...n),null!=t&&s("error",t,l.data)}o<=k.concurrency-k.buffer&&s("unsaturated"),k.idle()&&s("drain"),k.process()}}function d(e){return!!(0===e.length&&k.idle())&&(_e(()=>s("drain")),!0)}if(null==t)t=1;else if(0===t)throw new RangeError("Concurrency must not be zero");var p=c(e),o=0,h=[];const f={error:[],drain:[],saturated:[],unsaturated:[],empty:[]};var y=!1;const m=e=>t=>t?void(r(e),a(e,t)):new Promise((t,n)=>{i(e,(e,a)=>e?n(e):void t(a))});var g=!1,k={_tasks:new Ve,_createTaskItem(e,t){return{data:e,callback:t}},*[Symbol.iterator](){yield*k._tasks[Symbol.iterator]()},concurrency:t,payload:n,buffer:t/4,started:!1,paused:!1,push(e,t){return Array.isArray(e)?d(e)?void 0:e.map(e=>l(e,!1,!1,t)):l(e,!1,!1,t)},pushAsync(e,t){return Array.isArray(e)?d(e)?void 0:e.map(e=>l(e,!1,!0,t)):l(e,!1,!0,t)},kill(){r(),k._tasks.empty()},unshift(e,t){return Array.isArray(e)?d(e)?void 0:e.map(e=>l(e,!0,!1,t)):l(e,!0,!1,t)},unshiftAsync(e,t){return Array.isArray(e)?d(e)?void 0:e.map(e=>l(e,!0,!0,t)):l(e,!0,!0,t)},remove(e){k._tasks.remove(e)},process(){var e=Math.min;if(!g){for(g=!0;!k.paused&&o<k.concurrency&&k._tasks.length;){var t=[],n=[],a=k._tasks.length;k.payload&&(a=e(a,k.payload));for(var r,d=0;d<a;d++)r=k._tasks.shift(),t.push(r),h.push(r),n.push(r.data);o+=1,0===k._tasks.length&&s("empty"),o===k.concurrency&&s("saturated");var c=L(u(t));p(n,c)}g=!1}},length(){return k._tasks.length},running(){return o},workersList(){return h},idle(){return 0===k._tasks.length+o},pause(){k.paused=!0},resume(){!1===k.paused||(k.paused=!1,_e(k.process))}};return Object.defineProperties(k,{saturated:{writable:!1,value:m("saturated")},unsaturated:{writable:!1,value:m("unsaturated")},empty:{writable:!1,value:m("empty")},drain:{writable:!1,value:m("drain")},error:{writable:!1,value:m("error")}}),k}function T(e,t){return B(e,1,t)}function F(e,t,n){return B(e,t,n)}function C(...e){var t=e.map(c);return function(...e){var n=this,a=e[e.length-1];return"function"==typeof a?e.pop():a=b(),qe(t,e,(e,t,a)=>{t.apply(n,e.concat((e,...t)=>{a(e,t)}))},(e,t)=>a(e,...t)),a[Ce]}}function P(...e){return C(...e.reverse())}function R(...e){return function(...t){var n=t.pop();return n(null,...e)}}function z(e,t){return(n,a,i,r)=>{var s,l=!1;const u=c(i);n(a,(n,a,i)=>{u(n,(a,r)=>a||!1===a?i(a):e(r)&&!s?(l=!0,s=t(!0,n),i(null,be)):void i())},e=>e?r(e):void r(null,l?s:t(!1)))}}function N(e){return(t,...n)=>c(t)(...n,(t,...n)=>{"object"==typeof console&&(t?console.error&&console.error(t):console[e]&&n.forEach(t=>console[e](t)))})}function V(e,t,n){const a=c(t);return Xe(e,(...e)=>{const t=e.pop();a(...e,(e,n)=>t(e,!n))},n)}function Y(e){return(t,n,a)=>e(t,a)}function q(e){return u(e)?e:function(...t){var n=t.pop(),a=!0;t.push((...e)=>{a?_e(()=>n(...e)):n(...e)}),e.apply(this,t),a=!1}}function D(e,t,n,a){var r=Array(t.length);e(t,(e,t,a)=>{n(e,(e,n)=>{r[t]=!!n,a(e)})},e=>{if(e)return a(e);for(var n=[],s=0;s<t.length;s++)r[s]&&n.push(t[s]);a(null,n)})}function Q(e,t,n,a){var i=[];e(t,(e,t,a)=>{n(e,(n,r)=>n?a(n):void(r&&i.push({index:t,value:e}),a(n)))},e=>e?a(e):void a(null,i.sort((e,t)=>e.index-t.index).map(e=>e.value)))}function U(e,t,n,a){var i=y(t)?D:Q;return i(e,t,c(n),a)}function G(e,t,n){return ut(e,1/0,t,n)}function W(e,t,n){return ut(e,1,t,n)}function H(e,t,n){return pt(e,1/0,t,n)}function J(e,t,n){return pt(e,1,t,n)}function K(e,t=e=>e){var a=Object.create(null),r=Object.create(null),s=c(e),l=n((e,n)=>{var u=t(...e);u in a?_e(()=>n(null,...a[u])):u in r?r[u].push(n):(r[u]=[n],s(...e,(e,...t)=>{e||(a[u]=t);var n=r[u];delete r[u];for(var s=0,d=n.length;s<d;s++)n[s](e,...t)}))});return l.memo=a,l.unmemoized=e,l}function X(e,t){return ot(Me,e,t)}function Z(e,t,n){return ot(Ae(t),e,n)}function $(e,t){var n=c(e);return B((e,t)=>{n(e[0],t)},t,1)}function ee(e){return(e<<1)+1}function te(e){return(e+1>>1)-1}function ne(e,t){return e.priority===t.priority?e.pushCount<t.pushCount:e.priority<t.priority}function ae(e,t){function n(e,t){return Array.isArray(e)?e.map(e=>({data:e,priority:t})):{data:e,priority:t}}var a=$(e,t),{push:i,pushAsync:r}=a;return a._tasks=new ht,a._createTaskItem=({data:e,priority:t},n)=>({data:e,priority:t,callback:n}),a.push=function(e,t=0,a){return i(n(e,t),a)},a.pushAsync=function(e,t=0,a){return r(n(e,t),a)},delete a.unshift,delete a.unshiftAsync,a}function ie(e,t,n,a){var i=[...e].reverse();return qe(i,t,n,a)}function re(e){var t=c(e);return n(function(e,n){return e.push((e,...t)=>{let a={};if(e&&(a.error=e),0<t.length){var i=t;1>=t.length&&([i]=t),a.value=i}n(null,a)}),t.apply(this,e)})}function se(e){var t;return Array.isArray(e)?t=e.map(re):(t={},Object.keys(e).forEach(n=>{t[n]=re.call(this,e[n])})),t}function le(e,t,n,a){const i=c(n);return U(e,t,(e,t)=>{i(e,(e,n)=>{t(e,!n)})},a)}function ue(e){return function(){return e}}function de(e,t,n){function a(){r((e,...t)=>{!1===e||(e&&s++<i.times&&("function"!=typeof i.errorFilter||i.errorFilter(e))?setTimeout(a,i.intervalFunc(s-1)):n(e,...t))})}var i={times:kt,intervalFunc:ue(vt)};if(3>arguments.length&&"function"==typeof e?(n=t||b(),t=e):(pe(i,e),n=n||b()),"function"!=typeof t)throw new Error("Invalid arguments for async.retry");var r=c(t),s=1;return a(),n[Ce]}function pe(e,n){if("object"==typeof n)e.times=+n.times||kt,e.intervalFunc="function"==typeof n.interval?n.interval:ue(+n.interval||vt),e.errorFilter=n.errorFilter;else if("number"==typeof n||"string"==typeof n)e.times=+n||kt;else throw new Error("Invalid arguments for async.retry")}function ce(e,t){t||(t=e,e=null);let a=e&&e.arity||t.length;u(t)&&(a+=1);var i=c(t);return n((t,n)=>{function r(e){i(...t,e)}return(t.length<a-1||null==n)&&(t.push(n),n=b()),e?de(e,r,n):de(r,n),n[Ce]})}function oe(e,t){return ot(Be,e,t)}function he(e,t,a){var i=c(e);return n((n,r)=>{var s,l=!1;n.push((...e)=>{l||(r(...e),clearTimeout(s))}),s=setTimeout(function(){var t=e.name||"anonymous",n=new Error("Callback function \""+t+"\" timed out.");n.code="ETIMEDOUT",a&&(n.info=a),l=!0,r(n)},t),i(...n)})}function fe(e){for(var t=Array(e);e--;)t[e]=e;return t}function ye(e,t,n,a){var i=c(n);return De(fe(e),t,i,a)}function me(e,t,n){return ye(e,1/0,t,n)}function ge(e,t,n){return ye(e,1,t,n)}function ke(e,t,n,a){3>=arguments.length&&"function"==typeof t&&(a=n,n=t,t=Array.isArray(e)?[]:{}),a=m(a||b());var i=c(n);return Me(e,(e,n,a)=>{i(t,e,n,a)},e=>a(e,t)),a[Ce]}function ve(e){return(...t)=>(e.unmemoized||e)(...t)}function Se(e,t,n){const a=c(e);return _t(e=>a((t,n)=>e(t,!n)),t,n)}var xe,Le="function"==typeof queueMicrotask&&queueMicrotask,Ee="function"==typeof setImmediate&&setImmediate,Oe="object"==typeof process&&"function"==typeof process.nextTick;xe=Le?queueMicrotask:Ee?setImmediate:Oe?process.nextTick:a;var _e=i(xe);const be={};var Ae=e=>(t,n,a)=>{function i(e,t){if(!u)if(c-=1,e)l=!0,a(e);else if(!1===e)l=!0,u=!0;else{if(t===be||l&&0>=c)return l=!0,a(null);o||r()}}function r(){for(o=!0;c<e&&!l;){var t=s();if(null===t)return l=!0,void(0>=c&&a(null));c+=1,n(t.value,t.key,L(i))}o=!1}if(a=m(a),0>=e)throw new RangeError("concurrency limit cannot be less than 1");if(!t)return a(null);if(d(t))return E(t,e,n,a);if(p(t))return E(t[Symbol.asyncIterator](),e,n,a);var s=x(t),l=!1,u=!1,c=0,o=!1;r()},Ie=o(function(e,t,n,a){return Ae(t)(e,c(n),a)},4),Me=o(function(e,t,n){var a=y(e)?O:_;return a(e,c(t),n)},3),je=o(function(e,t,n){return f(Me,e,t,n)},3),we=h(je),Be=o(function(e,t,n){return Ie(e,1,t,n)},3),Te=o(function(e,t,n){return f(Be,e,t,n)},3),Fe=h(Te);const Ce=Symbol("promiseCallback");var Pe=/^(?:async\s+)?(?:function)?\s*\w*\s*\(\s*([^)]+)\s*\)(?:\s*{)/,Re=/^(?:async\s+)?\(?\s*([^)=]+)\s*\)?(?:\s*=>)/,ze=/,/,Ne=/(=.+)?(\s*)$/;class Ve{constructor(){this.head=this.tail=null,this.length=0}removeLink(e){return e.prev?e.prev.next=e.next:this.head=e.next,e.next?e.next.prev=e.prev:this.tail=e.prev,e.prev=e.next=null,this.length-=1,e}empty(){for(;this.head;)this.shift();return this}insertAfter(e,t){t.prev=e,t.next=e.next,e.next?e.next.prev=t:this.tail=t,e.next=t,this.length+=1}insertBefore(e,t){t.prev=e.prev,t.next=e,e.prev?e.prev.next=t:this.head=t,e.prev=t,this.length+=1}unshift(e){this.head?this.insertBefore(this.head,e):w(this,e)}push(e){this.tail?this.insertAfter(this.tail,e):w(this,e)}shift(){return this.head&&this.removeLink(this.head)}pop(){return this.tail&&this.removeLink(this.tail)}toArray(){return[...this]}*[Symbol.iterator](){for(var e=this.head;e;)yield e.data,e=e.next}remove(e){for(var t=this.head;t;){var{next:n}=t;e(t)&&this.removeLink(t),t=n}return this}}var Ye,qe=o(function(e,t,n,a){a=m(a);var r=c(n);return Be(e,(e,n,a)=>{r(t,e,(e,n)=>{t=n,a(e)})},e=>a(e,t))},4),De=o(function(e,t,n,a){return f(Ae(t),e,n,a)},4),Qe=o(function(e,t,n,a){var i=c(n);return De(e,t,(e,t)=>{i(e,(e,...n)=>e?t(e):t(e,n))},(e,t)=>{for(var n=[],r=0;r<t.length;r++)t[r]&&(n=n.concat(...t[r]));return a(e,n)})},4),Ue=o(function(e,t,n){return Qe(e,1/0,t,n)},3),Ge=o(function(e,t,n){return Qe(e,1,t,n)},3),We=o(function(e,t,n){return z(e=>e,(e,t)=>t)(Me,e,t,n)},3),He=o(function(e,t,n,a){return z(e=>e,(e,t)=>t)(Ae(t),e,n,a)},4),Je=o(function(e,t,n){return z(e=>e,(e,t)=>t)(Ae(1),e,t,n)},3),Ke=N("dir"),Xe=o(function(e,t,n){function a(e,...t){return e?n(e):void(!1===e||(r=t,l(...t,i)))}function i(e,t){return e?n(e):!1===e?void 0:t?void s(a):n(null,...r)}n=L(n);var r,s=c(e),l=c(t);return i(null,!0)},3),Ze=o(function(e,t,n){return Me(e,Y(c(t)),n)},3),$e=o(function(e,t,n,a){return Ae(t)(e,Y(c(n)),a)},4),et=o(function(e,t,n){return $e(e,1,t,n)},3),tt=o(function(e,t,n){return z(e=>!e,e=>!e)(Me,e,t,n)},3),nt=o(function(e,t,n,a){return z(e=>!e,e=>!e)(Ae(t),e,n,a)},4),at=o(function(e,t,n){return z(e=>!e,e=>!e)(Be,e,t,n)},3),it=o(function(e,t,n){return U(Me,e,t,n)},3),rt=o(function(e,t,n,a){return U(Ae(t),e,n,a)},4),st=o(function(e,t,n){return U(Be,e,t,n)},3),lt=o(function(e,t){function n(e){return e?a(e):void(!1===e||i(n))}var a=L(t),i=c(q(e));return n()},2),ut=o(function(e,t,n,a){var i=c(n);return De(e,t,(e,t)=>{i(e,(n,a)=>n?t(n):t(n,{key:a,val:e}))},(e,t)=>{for(var n={},{hasOwnProperty:r}=Object.prototype,s=0;s<t.length;s++)if(t[s]){var{key:l}=t[s],{val:u}=t[s];r.call(n,l)?n[l].push(u):n[l]=[u]}return a(e,n)})},4),dt=N("log"),pt=o(function(e,t,n,a){a=m(a);var i={},r=c(n);return Ae(t)(e,(e,t,n)=>{r(e,t,(e,a)=>e?n(e):void(i[t]=a,n(e)))},e=>a(e,i))},4);Ye=Oe?process.nextTick:Ee?setImmediate:a;var ct=i(Ye),ot=o((e,t,n)=>{var a=y(t)?[]:{};e(t,(e,t,n)=>{c(e)((e,...i)=>{2>i.length&&([i]=i),a[t]=i,n(e)})},e=>n(e,a))},3);class ht{constructor(){this.heap=[],this.pushCount=Number.MIN_SAFE_INTEGER}get length(){return this.heap.length}empty(){return this.heap=[],this}percUp(e){for(let n;0<e&&ne(this.heap[e],this.heap[n=te(e)]);){let a=this.heap[e];this.heap[e]=this.heap[n],this.heap[n]=a,e=n}}percDown(e){for(let n,a;(n=ee(e))<this.heap.length&&(n+1<this.heap.length&&ne(this.heap[n+1],this.heap[n])&&++n,!ne(this.heap[e],this.heap[n]));)a=this.heap[e],this.heap[e]=this.heap[n],this.heap[n]=a,e=n}push(e){e.pushCount=++this.pushCount,this.heap.push(e),this.percUp(this.heap.length-1)}unshift(e){return this.heap.push(e)}shift(){let[e]=this.heap;return this.heap[0]=this.heap[this.heap.length-1],this.heap.pop(),this.percDown(0),e}toArray(){return[...this]}*[Symbol.iterator](){for(let e=0;e<this.heap.length;e++)yield this.heap[e].data}remove(e){let t=0;for(let n=0;n<this.heap.length;n++)e(this.heap[n])||(this.heap[t]=this.heap[n],t++);this.heap.splice(t);for(let t=te(this.heap.length-1);0<=t;t--)this.percDown(t);return this}}var ft=o(function(e,t){if(t=m(t),!Array.isArray(e))return t(new TypeError("First argument to race must be an array of functions"));if(!e.length)return t();for(var n=0,a=e.length;n<a;n++)c(e[n])(t)},2),yt=o(function(e,t,n){return le(Me,e,t,n)},3),mt=o(function(e,t,n,a){return le(Ae(t),e,n,a)},4),gt=o(function(e,t,n){return le(Be,e,t,n)},3);const kt=5,vt=0;var St=o(function(e,t,n){return z(Boolean,e=>e)(Me,e,t,n)},3),xt=o(function(e,t,n,a){return z(Boolean,e=>e)(Ae(t),e,n,a)},4),Lt=o(function(e,t,n){return z(Boolean,e=>e)(Be,e,t,n)},3),Et=o(function(e,t,n){function a(e,t){var n=e.criteria,a=t.criteria;return n<a?-1:n>a?1:0}var i=c(t);return je(e,(e,t)=>{i(e,(n,a)=>n?t(n):void t(n,{value:e,criteria:a}))},(e,t)=>e?n(e):void n(null,t.sort(a).map(e=>e.value)))},3),Ot=o(function(e,t){var n,a=null;return et(e,(e,t)=>{c(e)((e,...i)=>!1===e?t(e):void(2>i.length?[n]=i:n=i,a=e,t(e?null:{})))},()=>t(a,n))}),_t=o(function(e,t,n){function a(e,...t){if(e)return n(e);l=t;!1===e||s(i)}function i(e,t){return e?n(e):!1===e?void 0:t?void r(a):n(null,...l)}n=L(n);var r=c(t),s=c(e),l=[];return s(i)},3),bt=o(function(e,t){function n(t){var n=c(e[i++]);n(...t,L(a))}function a(a,...r){return!1===a?void 0:a||i===e.length?t(a,...r):void n(r)}if(t=m(t),!Array.isArray(e))return t(new Error("First argument to waterfall must be an array of functions"));if(!e.length)return t();var i=0;n([])});e.default={apply:t,applyEach:we,applyEachSeries:Fe,asyncify:r,auto:A,autoInject:j,cargo:T,cargoQueue:F,compose:P,concat:Ue,concatLimit:Qe,concatSeries:Ge,constant:R,detect:We,detectLimit:He,detectSeries:Je,dir:Ke,doUntil:V,doWhilst:Xe,each:Ze,eachLimit:$e,eachOf:Me,eachOfLimit:Ie,eachOfSeries:Be,eachSeries:et,ensureAsync:q,every:tt,everyLimit:nt,everySeries:at,filter:it,filterLimit:rt,filterSeries:st,forever:lt,groupBy:G,groupByLimit:ut,groupBySeries:W,log:dt,map:je,mapLimit:De,mapSeries:Te,mapValues:H,mapValuesLimit:pt,mapValuesSeries:J,memoize:K,nextTick:ct,parallel:X,parallelLimit:Z,priorityQueue:ae,queue:$,race:ft,reduce:qe,reduceRight:ie,reflect:re,reflectAll:se,reject:yt,rejectLimit:mt,rejectSeries:gt,retry:de,retryable:ce,seq:C,series:oe,setImmediate:_e,some:St,someLimit:xt,someSeries:Lt,sortBy:Et,timeout:he,times:me,timesLimit:ye,timesSeries:ge,transform:ke,tryEach:Ot,unmemoize:ve,until:Se,waterfall:bt,whilst:_t,all:tt,allLimit:nt,allSeries:at,any:St,anyLimit:xt,anySeries:Lt,find:We,findLimit:He,findSeries:Je,flatMap:Ue,flatMapLimit:Qe,flatMapSeries:Ge,forEach:Ze,forEachSeries:et,forEachLimit:$e,forEachOf:Me,forEachOfSeries:Be,forEachOfLimit:Ie,inject:qe,foldl:qe,foldr:ie,select:it,selectLimit:rt,selectSeries:st,wrapSync:r,during:_t,doDuring:Xe},e.apply=t,e.applyEach=we,e.applyEachSeries=Fe,e.asyncify=r,e.auto=A,e.autoInject=j,e.cargo=T,e.cargoQueue=F,e.compose=P,e.concat=Ue,e.concatLimit=Qe,e.concatSeries=Ge,e.constant=R,e.detect=We,e.detectLimit=He,e.detectSeries=Je,e.dir=Ke,e.doUntil=V,e.doWhilst=Xe,e.each=Ze,e.eachLimit=$e,e.eachOf=Me,e.eachOfLimit=Ie,e.eachOfSeries=Be,e.eachSeries=et,e.ensureAsync=q,e.every=tt,e.everyLimit=nt,e.everySeries=at,e.filter=it,e.filterLimit=rt,e.filterSeries=st,e.forever=lt,e.groupBy=G,e.groupByLimit=ut,e.groupBySeries=W,e.log=dt,e.map=je,e.mapLimit=De,e.mapSeries=Te,e.mapValues=H,e.mapValuesLimit=pt,e.mapValuesSeries=J,e.memoize=K,e.nextTick=ct,e.parallel=X,e.parallelLimit=Z,e.priorityQueue=ae,e.queue=$,e.race=ft,e.reduce=qe,e.reduceRight=ie,e.reflect=re,e.reflectAll=se,e.reject=yt,e.rejectLimit=mt,e.rejectSeries=gt,e.retry=de,e.retryable=ce,e.seq=C,e.series=oe,e.setImmediate=_e,e.some=St,e.someLimit=xt,e.someSeries=Lt,e.sortBy=Et,e.timeout=he,e.times=me,e.timesLimit=ye,e.timesSeries=ge,e.transform=ke,e.tryEach=Ot,e.unmemoize=ve,e.until=Se,e.waterfall=bt,e.whilst=_t,e.all=tt,e.allLimit=nt,e.allSeries=at,e.any=St,e.anyLimit=xt,e.anySeries=Lt,e.find=We,e.findLimit=He,e.findSeries=Je,e.flatMap=Ue,e.flatMapLimit=Qe,e.flatMapSeries=Ge,e.forEach=Ze,e.forEachSeries=et,e.forEachLimit=$e,e.forEachOf=Me,e.forEachOfSeries=Be,e.forEachOfLimit=Ie,e.inject=qe,e.foldl=qe,e.foldr=ie,e.select=it,e.selectLimit=rt,e.selectSeries=st,e.wrapSync=r,e.during=_t,e.doDuring=Xe,Object.defineProperty(e,"__esModule",{value:!0})}); | ||
| (function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports):"function"==typeof define&&define.amd?define(["exports"],t):(e="undefined"==typeof globalThis?e||self:globalThis,t(e.async={}))})(this,function(e){"use strict";function t(e,...t){return(...n)=>e(...t,...n)}function n(e){return function(...t){var n=t.pop();return e.call(this,t,n)}}function a(e){setTimeout(e,0)}function i(e){return(t,...n)=>e(()=>t(...n))}function r(e){return d(e)?function(...t){const n=t.pop(),a=e.apply(this,t);return s(a,n)}:n(function(t,n){var a;try{a=e.apply(this,t)}catch(t){return n(t)}return a&&"function"==typeof a.then?s(a,n):void n(null,a)})}function s(e,t){return e.then(e=>{l(t,null,e)},e=>{l(t,e&&(e instanceof Error||e.message)?e:new Error(e))})}function l(e,t,n){try{e(t,n)}catch(e){_e(t=>{throw t},e)}}function d(e){return"AsyncFunction"===e[Symbol.toStringTag]}function u(e){return"AsyncGenerator"===e[Symbol.toStringTag]}function p(e){return"function"==typeof e[Symbol.asyncIterator]}function c(e){if("function"!=typeof e)throw new Error("expected a function");return d(e)?r(e):e}function o(e,t){function n(...n){return"function"==typeof n[t-1]?e.apply(this,n):new Promise((a,i)=>{n[t-1]=(e,...t)=>e?i(e):void a(1<t.length?t:t[0]),e.apply(this,n)})}if(t||(t=e.length),!t)throw new Error("arity is undefined");return n}function h(e){return function a(t,...n){const i=o(function(a){var i=this;return e(t,(e,t)=>{c(e).apply(i,n.concat(t))},a)});return i}}function f(e,t,n,a){t=t||[];var i=[],r=0,s=c(n);return e(t,(e,t,n)=>{var a=r++;s(e,(e,t)=>{i[a]=t,n(e)})},e=>{a(e,i)})}function y(e){return e&&"number"==typeof e.length&&0<=e.length&&0==e.length%1}function m(e){function t(...t){if(null!==e){var n=e;e=null,n.apply(this,t)}}return Object.assign(t,e),t}function g(e){return e[Symbol.iterator]&&e[Symbol.iterator]()}function k(e){var t=-1,n=e.length;return function a(){return++t<n?{value:e[t],key:t}:null}}function v(e){var t=-1;return function n(){var a=e.next();return a.done?null:(t++,{value:a.value,key:t})}}function S(e){var t=e?Object.keys(e):[],n=-1,a=t.length;return function i(){var r=t[++n];return"__proto__"===r?i():n<a?{value:e[r],key:r}:null}}function x(e){if(y(e))return k(e);var t=g(e);return t?v(t):S(e)}function L(e){return function(...t){if(null===e)throw new Error("Callback was already called.");var n=e;e=null,n.apply(this,t)}}function E(e,t,n,a){function i(){p>=t||u||l||(u=!0,e.next().then(({value:e,done:t})=>{if(!(d||l))return u=!1,t?(l=!0,void(0>=p&&a(null))):void(p++,n(e,c,r),c++,i())}).catch(s))}function r(e,t){return p-=1,d?void 0:e?s(e):!1===e?(l=!0,void(d=!0)):t===be||l&&0>=p?(l=!0,a(null)):void i()}function s(e){d||(u=!1,l=!0,a(e))}let l=!1,d=!1,u=!1,p=0,c=0;i()}function O(e,t,n){function a(e,t){!1===e&&(l=!0);!0===l||(e?n(e):(++r===s||t===be)&&n(null))}n=m(n);var i=0,r=0,{length:s}=e,l=!1;for(0===s&&n(null);i<s;i++)t(e[i],i,L(a))}function _(e,t,n){return Ie(e,1/0,t,n)}function b(){function e(e,...a){return e?n(e):void t(1<a.length?a:a[0])}let t,n;return e[Ce]=new Promise((e,a)=>{t=e,n=a}),e}function A(e,t,n){function a(e,t){k.push(()=>l(e,t))}function i(){if(!f){if(0===k.length&&0===h)return n(null,o);for(;k.length&&h<t;){var e=k.shift();e()}}}function r(e,t){var n=g[e];n||(n=g[e]=[]),n.push(t)}function s(e){var t=g[e]||[];t.forEach(e=>e()),i()}function l(e,t){if(!y){var a=L((t,...a)=>{if(h--,!1===t)return void(f=!0);if(2>a.length&&([a]=a),t){var i={};if(Object.keys(o).forEach(e=>{i[e]=o[e]}),i[e]=a,y=!0,g=Object.create(null),f)return;n(t,i)}else o[e]=a,s(e)});h++;var i=c(t[t.length-1]);1<t.length?i(o,a):i(a)}}function d(){for(var e,t=0;v.length;)e=v.pop(),t++,u(e).forEach(e=>{0==--S[e]&&v.push(e)});if(t!==p)throw new Error("async.auto cannot execute tasks due to a recursive dependency")}function u(t){var n=[];return Object.keys(e).forEach(a=>{const i=e[a];Array.isArray(i)&&0<=i.indexOf(t)&&n.push(a)}),n}"number"!=typeof t&&(n=t,t=null),n=m(n||b());var p=Object.keys(e).length;if(!p)return n(null);t||(t=p);var o={},h=0,f=!1,y=!1,g=Object.create(null),k=[],v=[],S={};return Object.keys(e).forEach(t=>{var n=e[t];if(!Array.isArray(n))return a(t,[n]),void v.push(t);var i=n.slice(0,n.length-1),s=i.length;return 0===s?(a(t,n),void v.push(t)):void(S[t]=s,i.forEach(l=>{if(!e[l])throw new Error("async.auto task `"+t+"` has a non-existent dependency `"+l+"` in "+i.join(", "));r(l,()=>{s--,0===s&&a(t,n)})}))}),d(),i(),n[Ce]}function I(e){let t="",n=0,a=e.indexOf("*/");for(;n<e.length;)if("/"===e[n]&&"/"===e[n+1]){let t=e.indexOf("\n",n);n=-1===t?e.length:t}else if(-1!==a&&"/"===e[n]&&"*"===e[n+1]){let i=e.indexOf("*/",n);-1===i?(t+=e[n],n++):(n=i+2,a=e.indexOf("*/",n))}else t+=e[n],n++;return t}function M(e){const t=I(e.toString());let n=t.match(Pe);if(n||(n=t.match(Re)),!n)throw new Error("could not parse args in autoInject\nSource:\n"+t);let[,a]=n;return a.replace(/\s/g,"").split(ze).map(e=>e.replace(Ne,"").trim())}function j(e,t){var n={};return Object.keys(e).forEach(t=>{function a(e,t){var n=i.map(t=>e[t]);n.push(t),c(r)(...n)}var i,r=e[t],s=d(r),l=!s&&1===r.length||s&&0===r.length;if(Array.isArray(r))i=[...r],r=i.pop(),n[t]=i.concat(0<i.length?a:r);else if(l)n[t]=r;else{if(i=M(r),0===r.length&&!s&&0===i.length)throw new Error("autoInject task functions require explicit parameters.");s||i.pop(),n[t]=i.concat(a)}}),A(n,t)}function w(e,t){e.length=1,e.head=e.tail=t}function B(e,t,n){function a(e,t){f[e].push(t)}function i(e,t){const n=(...a)=>{r(e,n),t(...a)};f[e].push(n)}function r(e,t){return e?t?void(f[e]=f[e].filter(e=>e!==t)):f[e]=[]:Object.keys(f).forEach(e=>f[e]=[])}function s(e,...t){f[e].forEach(e=>e(...t))}function l(e,t,n,a){function i(e,...t){return e?n?s(e):r():1>=t.length?r(t[0]):void r(t)}if(null!=a&&"function"!=typeof a)throw new Error("task callback must be a function");k.started=!0;var r,s,l=k._createTaskItem(e,n?i:a||i);if(t?k._tasks.unshift(l):k._tasks.push(l),y||(y=!0,_e(()=>{y=!1,k.process()})),n||!a)return new Promise((e,t)=>{r=e,s=t})}function d(e){return function(t,...n){o-=1;for(var a=0,r=e.length;a<r;a++){var l=e[a],d=h.indexOf(l);0===d?h.shift():0<d&&h.splice(d,1),l.callback(t,...n),null!=t&&s("error",t,l.data)}o<=k.concurrency-k.buffer&&s("unsaturated"),k.idle()&&s("drain"),k.process()}}function u(e){return!!(0===e.length&&k.idle())&&(_e(()=>s("drain")),!0)}if(null==t)t=1;else if(0===t)throw new RangeError("Concurrency must not be zero");var p=c(e),o=0,h=[];const f={error:[],drain:[],saturated:[],unsaturated:[],empty:[]};var y=!1;const m=e=>t=>t?void(r(e),a(e,t)):new Promise((t,n)=>{i(e,(e,a)=>e?n(e):void t(a))});var g=!1,k={_tasks:new Ve,_createTaskItem(e,t){return{data:e,callback:t}},*[Symbol.iterator](){yield*k._tasks[Symbol.iterator]()},concurrency:t,payload:n,buffer:t/4,started:!1,paused:!1,push(e,t){return Array.isArray(e)?u(e)?void 0:e.map(e=>l(e,!1,!1,t)):l(e,!1,!1,t)},pushAsync(e,t){return Array.isArray(e)?u(e)?void 0:e.map(e=>l(e,!1,!0,t)):l(e,!1,!0,t)},kill(){r(),k._tasks.empty()},unshift(e,t){return Array.isArray(e)?u(e)?void 0:e.map(e=>l(e,!0,!1,t)):l(e,!0,!1,t)},unshiftAsync(e,t){return Array.isArray(e)?u(e)?void 0:e.map(e=>l(e,!0,!0,t)):l(e,!0,!0,t)},remove(e){k._tasks.remove(e)},process(){var e=Math.min;if(!g){for(g=!0;!k.paused&&o<k.concurrency&&k._tasks.length;){var t=[],n=[],a=k._tasks.length;k.payload&&(a=e(a,k.payload));for(var r,u=0;u<a;u++)r=k._tasks.shift(),t.push(r),h.push(r),n.push(r.data);o+=1,0===k._tasks.length&&s("empty"),o===k.concurrency&&s("saturated");var c=L(d(t));p(n,c)}g=!1}},length(){return k._tasks.length},running(){return o},workersList(){return h},idle(){return 0===k._tasks.length+o},pause(){k.paused=!0},resume(){!1===k.paused||(k.paused=!1,_e(k.process))}};return Object.defineProperties(k,{saturated:{writable:!1,value:m("saturated")},unsaturated:{writable:!1,value:m("unsaturated")},empty:{writable:!1,value:m("empty")},drain:{writable:!1,value:m("drain")},error:{writable:!1,value:m("error")}}),k}function T(e,t){return B(e,1,t)}function F(e,t,n){return B(e,t,n)}function C(...e){var t=e.map(c);return function(...e){var n=this,a=e[e.length-1];return"function"==typeof a?e.pop():a=b(),qe(t,e,(e,t,a)=>{t.apply(n,e.concat((e,...t)=>{a(e,t)}))},(e,t)=>a(e,...t)),a[Ce]}}function P(...e){return C(...e.reverse())}function R(...e){return function(...t){var n=t.pop();return n(null,...e)}}function z(e,t){return(n,a,i,r)=>{var s,l=!1;const d=c(i);n(a,(n,a,i)=>{d(n,(a,r)=>a||!1===a?i(a):e(r)&&!s?(l=!0,s=t(!0,n),i(null,be)):void i())},e=>e?r(e):void r(null,l?s:t(!1)))}}function N(e){return(t,...n)=>c(t)(...n,(t,...n)=>{"object"==typeof console&&(t?console.error&&console.error(t):console[e]&&n.forEach(t=>console[e](t)))})}function V(e,t,n){const a=c(t);return Xe(e,(...e)=>{const t=e.pop();a(...e,(e,n)=>t(e,!n))},n)}function Y(e){return(t,n,a)=>e(t,a)}function q(e){return d(e)?e:function(...t){var n=t.pop(),a=!0;t.push((...e)=>{a?_e(()=>n(...e)):n(...e)}),e.apply(this,t),a=!1}}function D(e,t,n,a){var r=Array(t.length);e(t,(e,t,a)=>{n(e,(e,n)=>{r[t]=!!n,a(e)})},e=>{if(e)return a(e);for(var n=[],s=0;s<t.length;s++)r[s]&&n.push(t[s]);a(null,n)})}function Q(e,t,n,a){var i=[];e(t,(e,t,a)=>{n(e,(n,r)=>n?a(n):void(r&&i.push({index:t,value:e}),a(n)))},e=>e?a(e):void a(null,i.sort((e,t)=>e.index-t.index).map(e=>e.value)))}function U(e,t,n,a){var i=y(t)?D:Q;return i(e,t,c(n),a)}function G(e,t,n){return dt(e,1/0,t,n)}function W(e,t,n){return dt(e,1,t,n)}function H(e,t,n){return pt(e,1/0,t,n)}function J(e,t,n){return pt(e,1,t,n)}function K(e,t=e=>e){var a=Object.create(null),r=Object.create(null),s=c(e),l=n((e,n)=>{var d=t(...e);d in a?_e(()=>n(null,...a[d])):d in r?r[d].push(n):(r[d]=[n],s(...e,(e,...t)=>{e||(a[d]=t);var n=r[d];delete r[d];for(var s=0,u=n.length;s<u;s++)n[s](e,...t)}))});return l.memo=a,l.unmemoized=e,l}function X(e,t){return ot(Me,e,t)}function Z(e,t,n){return ot(Ae(t),e,n)}function $(e,t){var n=c(e);return B((e,t)=>{n(e[0],t)},t,1)}function ee(e){return(e<<1)+1}function te(e){return(e+1>>1)-1}function ne(e,t){return e.priority===t.priority?e.pushCount<t.pushCount:e.priority<t.priority}function ae(e,t){function n(e,t){return Array.isArray(e)?e.map(e=>({data:e,priority:t})):{data:e,priority:t}}var a=$(e,t),{push:i,pushAsync:r}=a;return a._tasks=new ht,a._createTaskItem=({data:e,priority:t},n)=>({data:e,priority:t,callback:n}),a.push=function(e,t=0,a){return i(n(e,t),a)},a.pushAsync=function(e,t=0,a){return r(n(e,t),a)},delete a.unshift,delete a.unshiftAsync,a}function ie(e,t,n,a){var i=[...e].reverse();return qe(i,t,n,a)}function re(e){var t=c(e);return n(function a(e,n){return e.push((e,...t)=>{let a={};if(e&&(a.error=e),0<t.length){var i=t;1>=t.length&&([i]=t),a.value=i}n(null,a)}),t.apply(this,e)})}function se(e){var t;return Array.isArray(e)?t=e.map(re):(t={},Object.keys(e).forEach(n=>{t[n]=re.call(this,e[n])})),t}function le(e,t,n,a){const i=c(n);return U(e,t,(e,t)=>{i(e,(e,n)=>{t(e,!n)})},a)}function de(e){return function(){return e}}function ue(e,t,n){function a(){r((e,...t)=>{!1===e||(e&&s++<i.times&&("function"!=typeof i.errorFilter||i.errorFilter(e))?setTimeout(a,i.intervalFunc(s-1)):n(e,...t))})}var i={times:kt,intervalFunc:de(vt)};if(3>arguments.length&&"function"==typeof e?(n=t||b(),t=e):(pe(i,e),n=n||b()),"function"!=typeof t)throw new Error("Invalid arguments for async.retry");var r=c(t),s=1;return a(),n[Ce]}function pe(e,n){if("object"==typeof n)e.times=+n.times||kt,e.intervalFunc="function"==typeof n.interval?n.interval:de(+n.interval||vt),e.errorFilter=n.errorFilter;else if("number"==typeof n||"string"==typeof n)e.times=+n||kt;else throw new Error("Invalid arguments for async.retry")}function ce(e,t){t||(t=e,e=null);let a=e&&e.arity||t.length;d(t)&&(a+=1);var i=c(t);return n((t,n)=>{function r(e){i(...t,e)}return(t.length<a-1||null==n)&&(t.push(n),n=b()),e?ue(e,r,n):ue(r,n),n[Ce]})}function oe(e,t){return ot(Be,e,t)}function he(e,t,a){var i=c(e);return n((n,r)=>{function s(){var t=e.name||"anonymous",n=new Error("Callback function \""+t+"\" timed out.");n.code="ETIMEDOUT",a&&(n.info=a),d=!0,r(n)}var l,d=!1;n.push((...e)=>{d||(r(...e),clearTimeout(l))}),l=setTimeout(s,t),i(...n)})}function fe(e){for(var t=Array(e);e--;)t[e]=e;return t}function ye(e,t,n,a){var i=c(n);return De(fe(e),t,i,a)}function me(e,t,n){return ye(e,1/0,t,n)}function ge(e,t,n){return ye(e,1,t,n)}function ke(e,t,n,a){3>=arguments.length&&"function"==typeof t&&(a=n,n=t,t=Array.isArray(e)?[]:{}),a=m(a||b());var i=c(n);return Me(e,(e,n,a)=>{i(t,e,n,a)},e=>a(e,t)),a[Ce]}function ve(e){return(...t)=>(e.unmemoized||e)(...t)}function Se(e,t,n){const a=c(e);return _t(e=>a((t,n)=>e(t,!n)),t,n)}var xe,Le="function"==typeof queueMicrotask&&queueMicrotask,Ee="function"==typeof setImmediate&&setImmediate,Oe="object"==typeof process&&"function"==typeof process.nextTick;xe=Le?queueMicrotask:Ee?setImmediate:Oe?process.nextTick:a;var _e=i(xe);var be={},Ae=e=>(t,n,a)=>{function i(e,t){if(!d)if(c-=1,e)l=!0,a(e);else if(!1===e)l=!0,d=!0;else{if(t===be||l&&0>=c)return l=!0,a(null);o||r()}}function r(){for(o=!0;c<e&&!l;){var t=s();if(null===t)return l=!0,void(0>=c&&a(null));c+=1,n(t.value,t.key,L(i))}o=!1}if(a=m(a),0>=e)throw new RangeError("concurrency limit cannot be less than 1");if(!t)return a(null);if(u(t))return E(t,e,n,a);if(p(t))return E(t[Symbol.asyncIterator](),e,n,a);var s=x(t),l=!1,d=!1,c=0,o=!1;r()},Ie=o(function i(e,t,n,a){return Ae(t)(e,c(n),a)},4),Me=o(function a(e,t,n){var i=y(e)?O:_;return i(e,c(t),n)},3),je=o(function a(e,t,n){return f(Me,e,t,n)},3),we=h(je),Be=o(function a(e,t,n){return Ie(e,1,t,n)},3),Te=o(function a(e,t,n){return f(Be,e,t,n)},3),Fe=h(Te);const Ce=Symbol("promiseCallback");var Pe=/^(?:async\s+)?(?:function)?\s*\w*\s*\(\s*([^)]+)\s*\)(?:\s*{)/,Re=/^(?:async\s+)?\(?\s*([^)=]+)\s*\)?(?:\s*=>)/,ze=/,/,Ne=/(=.+)?(\s*)$/;class Ve{constructor(){this.head=this.tail=null,this.length=0}removeLink(e){return e.prev?e.prev.next=e.next:this.head=e.next,e.next?e.next.prev=e.prev:this.tail=e.prev,e.prev=e.next=null,this.length-=1,e}empty(){for(;this.head;)this.shift();return this}insertAfter(e,t){t.prev=e,t.next=e.next,e.next?e.next.prev=t:this.tail=t,e.next=t,this.length+=1}insertBefore(e,t){t.prev=e.prev,t.next=e,e.prev?e.prev.next=t:this.head=t,e.prev=t,this.length+=1}unshift(e){this.head?this.insertBefore(this.head,e):w(this,e)}push(e){this.tail?this.insertAfter(this.tail,e):w(this,e)}shift(){return this.head&&this.removeLink(this.head)}pop(){return this.tail&&this.removeLink(this.tail)}toArray(){return[...this]}*[Symbol.iterator](){for(var e=this.head;e;)yield e.data,e=e.next}remove(e){for(var t=this.head;t;){var{next:n}=t;e(t)&&this.removeLink(t),t=n}return this}}var Ye,qe=o(function i(e,t,n,a){a=m(a);var r=c(n);return Be(e,(e,n,a)=>{r(t,e,(e,n)=>{t=n,a(e)})},e=>a(e,t))},4),De=o(function i(e,t,n,a){return f(Ae(t),e,n,a)},4),Qe=o(function i(e,t,n,a){var r=c(n);return De(e,t,(e,t)=>{r(e,(e,...n)=>e?t(e):t(e,n))},(e,t)=>{for(var n=[],r=0;r<t.length;r++)t[r]&&(n=n.concat(...t[r]));return a(e,n)})},4),Ue=o(function a(e,t,n){return Qe(e,1/0,t,n)},3),Ge=o(function a(e,t,n){return Qe(e,1,t,n)},3),We=o(function a(e,t,n){return z(e=>e,(e,t)=>t)(Me,e,t,n)},3),He=o(function i(e,t,n,a){return z(e=>e,(e,t)=>t)(Ae(t),e,n,a)},4),Je=o(function a(e,t,n){return z(e=>e,(e,t)=>t)(Ae(1),e,t,n)},3),Ke=N("dir"),Xe=o(function a(e,t,n){function i(e,...t){return e?n(e):void(!1===e||(s=t,d(...t,r)))}function r(e,t){return e?n(e):!1===e?void 0:t?void l(i):n(null,...s)}n=L(n);var s,l=c(e),d=c(t);return r(null,!0)},3),Ze=o(function a(e,t,n){return Me(e,Y(c(t)),n)},3),$e=o(function i(e,t,n,a){return Ae(t)(e,Y(c(n)),a)},4),et=o(function a(e,t,n){return $e(e,1,t,n)},3),tt=o(function a(e,t,n){return z(e=>!e,e=>!e)(Me,e,t,n)},3),nt=o(function i(e,t,n,a){return z(e=>!e,e=>!e)(Ae(t),e,n,a)},4),at=o(function a(e,t,n){return z(e=>!e,e=>!e)(Be,e,t,n)},3),it=o(function a(e,t,n){return U(Me,e,t,n)},3),rt=o(function i(e,t,n,a){return U(Ae(t),e,n,a)},4),st=o(function a(e,t,n){return U(Be,e,t,n)},3),lt=o(function n(e,t){function a(e){return e?i(e):void(!1===e||r(a))}var i=L(t),r=c(q(e));return a()},2),dt=o(function i(e,t,n,a){var r=c(n);return De(e,t,(e,t)=>{r(e,(n,a)=>n?t(n):t(n,{key:a,val:e}))},(e,t)=>{for(var n={},{hasOwnProperty:r}=Object.prototype,s=0;s<t.length;s++)if(t[s]){var{key:l}=t[s],{val:d}=t[s];r.call(n,l)?n[l].push(d):n[l]=[d]}return a(e,n)})},4),ut=N("log"),pt=o(function i(e,t,n,a){a=m(a);var r={},s=c(n);return Ae(t)(e,(e,t,n)=>{s(e,t,(e,a)=>e?n(e):void(r[t]=a,n(e)))},e=>a(e,r))},4);Ye=Oe?process.nextTick:Ee?setImmediate:a;var ct=i(Ye),ot=o((e,t,n)=>{var a=y(t)?[]:{};e(t,(e,t,n)=>{c(e)((e,...i)=>{2>i.length&&([i]=i),a[t]=i,n(e)})},e=>n(e,a))},3);class ht{constructor(){this.heap=[],this.pushCount=Number.MIN_SAFE_INTEGER}get length(){return this.heap.length}empty(){return this.heap=[],this}percUp(e){for(let n;0<e&&ne(this.heap[e],this.heap[n=te(e)]);){let a=this.heap[e];this.heap[e]=this.heap[n],this.heap[n]=a,e=n}}percDown(e){for(let n,a;(n=ee(e))<this.heap.length&&(n+1<this.heap.length&&ne(this.heap[n+1],this.heap[n])&&++n,!ne(this.heap[e],this.heap[n]));)a=this.heap[e],this.heap[e]=this.heap[n],this.heap[n]=a,e=n}push(e){e.pushCount=++this.pushCount,this.heap.push(e),this.percUp(this.heap.length-1)}unshift(e){return this.heap.push(e)}shift(){let[e]=this.heap;return this.heap[0]=this.heap[this.heap.length-1],this.heap.pop(),this.percDown(0),e}toArray(){return[...this]}*[Symbol.iterator](){for(let e=0;e<this.heap.length;e++)yield this.heap[e].data}remove(e){let t=0;for(let n=0;n<this.heap.length;n++)e(this.heap[n])||(this.heap[t]=this.heap[n],t++);this.heap.splice(t);for(let t=te(this.heap.length-1);0<=t;t--)this.percDown(t);return this}}var ft=o(function n(e,t){if(t=m(t),!Array.isArray(e))return t(new TypeError("First argument to race must be an array of functions"));if(!e.length)return t();for(var a=0,r=e.length;a<r;a++)c(e[a])(t)},2),yt=o(function a(e,t,n){return le(Me,e,t,n)},3),mt=o(function i(e,t,n,a){return le(Ae(t),e,n,a)},4),gt=o(function a(e,t,n){return le(Be,e,t,n)},3);const kt=5,vt=0;var St=o(function a(e,t,n){return z(Boolean,e=>e)(Me,e,t,n)},3),xt=o(function i(e,t,n,a){return z(Boolean,e=>e)(Ae(t),e,n,a)},4),Lt=o(function a(e,t,n){return z(Boolean,e=>e)(Be,e,t,n)},3),Et=o(function a(e,t,n){function i(e,t){var n=e.criteria,a=t.criteria;return n<a?-1:n>a?1:0}var r=c(t);return je(e,(e,t)=>{r(e,(n,a)=>n?t(n):void t(n,{value:e,criteria:a}))},(e,t)=>e?n(e):void n(null,t.sort(i).map(e=>e.value)))},3),Ot=o(function n(e,t){var a,i=null;return et(e,(e,t)=>{c(e)((e,...n)=>!1===e?t(e):void(2>n.length?[a]=n:a=n,i=e,t(e?null:{})))},()=>t(i,a))}),_t=o(function a(e,t,n){function i(e,...t){if(e)return n(e);d=t;!1===e||l(r)}function r(e,t){return e?n(e):!1===e?void 0:t?void s(i):n(null,...d)}n=L(n);var s=c(t),l=c(e),d=[];return l(r)},3),bt=o(function n(e,t){function a(t){var n=c(e[r++]);n(...t,L(i))}function i(n,...i){return!1===n?void 0:n||r===e.length?t(n,...i):void a(i)}if(t=m(t),!Array.isArray(e))return t(new Error("First argument to waterfall must be an array of functions"));if(!e.length)return t();var r=0;a([])});e.all=tt,e.allLimit=nt,e.allSeries=at,e.any=St,e.anyLimit=xt,e.anySeries=Lt,e.apply=t,e.applyEach=we,e.applyEachSeries=Fe,e.asyncify=r,e.auto=A,e.autoInject=j,e.cargo=T,e.cargoQueue=F,e.compose=P,e.concat=Ue,e.concatLimit=Qe,e.concatSeries=Ge,e.constant=R,e.default={apply:t,applyEach:we,applyEachSeries:Fe,asyncify:r,auto:A,autoInject:j,cargo:T,cargoQueue:F,compose:P,concat:Ue,concatLimit:Qe,concatSeries:Ge,constant:R,detect:We,detectLimit:He,detectSeries:Je,dir:Ke,doUntil:V,doWhilst:Xe,each:Ze,eachLimit:$e,eachOf:Me,eachOfLimit:Ie,eachOfSeries:Be,eachSeries:et,ensureAsync:q,every:tt,everyLimit:nt,everySeries:at,filter:it,filterLimit:rt,filterSeries:st,forever:lt,groupBy:G,groupByLimit:dt,groupBySeries:W,log:ut,map:je,mapLimit:De,mapSeries:Te,mapValues:H,mapValuesLimit:pt,mapValuesSeries:J,memoize:K,nextTick:ct,parallel:X,parallelLimit:Z,priorityQueue:ae,queue:$,race:ft,reduce:qe,reduceRight:ie,reflect:re,reflectAll:se,reject:yt,rejectLimit:mt,rejectSeries:gt,retry:ue,retryable:ce,seq:C,series:oe,setImmediate:_e,some:St,someLimit:xt,someSeries:Lt,sortBy:Et,timeout:he,times:me,timesLimit:ye,timesSeries:ge,transform:ke,tryEach:Ot,unmemoize:ve,until:Se,waterfall:bt,whilst:_t,all:tt,allLimit:nt,allSeries:at,any:St,anyLimit:xt,anySeries:Lt,find:We,findLimit:He,findSeries:Je,flatMap:Ue,flatMapLimit:Qe,flatMapSeries:Ge,forEach:Ze,forEachSeries:et,forEachLimit:$e,forEachOf:Me,forEachOfSeries:Be,forEachOfLimit:Ie,inject:qe,foldl:qe,foldr:ie,select:it,selectLimit:rt,selectSeries:st,wrapSync:r,during:_t,doDuring:Xe},e.detect=We,e.detectLimit=He,e.detectSeries=Je,e.dir=Ke,e.doDuring=Xe,e.doUntil=V,e.doWhilst=Xe,e.during=_t,e.each=Ze,e.eachLimit=$e,e.eachOf=Me,e.eachOfLimit=Ie,e.eachOfSeries=Be,e.eachSeries=et,e.ensureAsync=q,e.every=tt,e.everyLimit=nt,e.everySeries=at,e.filter=it,e.filterLimit=rt,e.filterSeries=st,e.find=We,e.findLimit=He,e.findSeries=Je,e.flatMap=Ue,e.flatMapLimit=Qe,e.flatMapSeries=Ge,e.foldl=qe,e.foldr=ie,e.forEach=Ze,e.forEachLimit=$e,e.forEachOf=Me,e.forEachOfLimit=Ie,e.forEachOfSeries=Be,e.forEachSeries=et,e.forever=lt,e.groupBy=G,e.groupByLimit=dt,e.groupBySeries=W,e.inject=qe,e.log=ut,e.map=je,e.mapLimit=De,e.mapSeries=Te,e.mapValues=H,e.mapValuesLimit=pt,e.mapValuesSeries=J,e.memoize=K,e.nextTick=ct,e.parallel=X,e.parallelLimit=Z,e.priorityQueue=ae,e.queue=$,e.race=ft,e.reduce=qe,e.reduceRight=ie,e.reflect=re,e.reflectAll=se,e.reject=yt,e.rejectLimit=mt,e.rejectSeries=gt,e.retry=ue,e.retryable=ce,e.select=it,e.selectLimit=rt,e.selectSeries=st,e.seq=C,e.series=oe,e.setImmediate=_e,e.some=St,e.someLimit=xt,e.someSeries=Lt,e.sortBy=Et,e.timeout=he,e.times=me,e.timesLimit=ye,e.timesSeries=ge,e.transform=ke,e.tryEach=Ot,e.unmemoize=ve,e.until=Se,e.waterfall=bt,e.whilst=_t,e.wrapSync=r,Object.defineProperty(e,"__esModule",{value:!0})}); |
@@ -68,2 +68,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(doWhilst, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -46,2 +46,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -68,2 +68,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(doWhilst, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -31,3 +31,3 @@ 'use strict'; | ||
| * @param {AsyncFunction} test - asynchronous truth test to perform before each | ||
| * execution of `iteratee`. Invoked with (). | ||
| * execution of `iteratee`. Invoked with (callback). | ||
| * @param {AsyncFunction} iteratee - An async function which is called each time | ||
@@ -79,2 +79,2 @@ * `test` passes. Invoked with (callback). | ||
| exports.default = (0, _awaitify2.default)(whilst, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -125,6 +125,6 @@ | ||
| function eachLimit(coll, iteratee, callback) { | ||
| return (0, _eachOf2.default)(coll, (0, _withoutIndex2.default)((0, _wrapAsync2.default)(iteratee)), callback); | ||
| return (0, _eachOf2.default)(coll, (0, _withoutIndex2.default)((0, _wrapAsync2.default)(iteratee)), callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(eachLimit, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -47,5 +47,5 @@ | ||
| function eachLimit(coll, limit, iteratee, callback) { | ||
| return (0, _eachOfLimit2.default)(limit)(coll, (0, _withoutIndex2.default)((0, _wrapAsync2.default)(iteratee)), callback); | ||
| return (0, _eachOfLimit2.default)(limit)(coll, (0, _withoutIndex2.default)((0, _wrapAsync2.default)(iteratee)), callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(eachLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -185,2 +185,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(eachOf, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -43,6 +43,6 @@ | ||
| function eachOfLimit(coll, limit, iteratee, callback) { | ||
| return (0, _eachOfLimit3.default)(limit)(coll, (0, _wrapAsync2.default)(iteratee), callback); | ||
| return (0, _eachOfLimit3.default)(limit)(coll, (0, _wrapAsync2.default)(iteratee), callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(eachOfLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -36,5 +36,5 @@ | ||
| function eachOfSeries(coll, iteratee, callback) { | ||
| return (0, _eachOfLimit2.default)(coll, 1, iteratee, callback); | ||
| return (0, _eachOfLimit2.default)(coll, 1, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(eachOfSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -41,5 +41,5 @@ | ||
| function eachSeries(coll, iteratee, callback) { | ||
| return (0, _eachLimit2.default)(coll, 1, iteratee, callback); | ||
| return (0, _eachLimit2.default)(coll, 1, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(eachSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -67,2 +67,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -116,5 +116,5 @@ | ||
| function every(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)(_eachOf2.default, coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)(_eachOf2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(every, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -43,5 +43,5 @@ | ||
| function everyLimit(coll, limit, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(everyLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -42,5 +42,5 @@ | ||
| function everySeries(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => !bool, res => !res)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(everySeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -90,5 +90,5 @@ | ||
| function filter(coll, iteratee, callback) { | ||
| return (0, _filter3.default)(_eachOf2.default, coll, iteratee, callback); | ||
| return (0, _filter3.default)(_eachOf2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(filter, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -42,5 +42,5 @@ | ||
| function filterLimit(coll, limit, iteratee, callback) { | ||
| return (0, _filter3.default)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| return (0, _filter3.default)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(filterLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -40,5 +40,5 @@ | ||
| function filterSeries(coll, iteratee, callback) { | ||
| return (0, _filter3.default)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| return (0, _filter3.default)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(filterSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -93,5 +93,5 @@ | ||
| function detect(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)(_eachOf2.default, coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)(_eachOf2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(detect, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -45,5 +45,5 @@ | ||
| function detectLimit(coll, limit, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(detectLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -43,6 +43,6 @@ | ||
| function detectSeries(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)((0, _eachOfLimit2.default)(1), coll, iteratee, callback); | ||
| return (0, _createTester2.default)(bool => bool, (res, item) => item)((0, _eachOfLimit2.default)(1), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(detectSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -112,5 +112,5 @@ | ||
| function concat(coll, iteratee, callback) { | ||
| return (0, _concatLimit2.default)(coll, Infinity, iteratee, callback); | ||
| return (0, _concatLimit2.default)(coll, Infinity, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(concat, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -60,2 +60,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(concatLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -38,5 +38,5 @@ | ||
| function concatSeries(coll, iteratee, callback) { | ||
| return (0, _concatLimit2.default)(coll, 1, iteratee, callback); | ||
| return (0, _concatLimit2.default)(coll, 1, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(concatSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -153,2 +153,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(reduce, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -38,5 +38,5 @@ exports.default = reduceRight; | ||
| function reduceRight(array, memo, iteratee, callback) { | ||
| var reversed = [...array].reverse(); | ||
| return (0, _reduce2.default)(reversed, memo, iteratee, callback); | ||
| var reversed = [...array].reverse(); | ||
| return (0, _reduce2.default)(reversed, memo, iteratee, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -125,6 +125,6 @@ | ||
| function eachLimit(coll, iteratee, callback) { | ||
| return (0, _eachOf2.default)(coll, (0, _withoutIndex2.default)((0, _wrapAsync2.default)(iteratee)), callback); | ||
| return (0, _eachOf2.default)(coll, (0, _withoutIndex2.default)((0, _wrapAsync2.default)(iteratee)), callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(eachLimit, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -47,5 +47,5 @@ | ||
| function eachLimit(coll, limit, iteratee, callback) { | ||
| return (0, _eachOfLimit2.default)(limit)(coll, (0, _withoutIndex2.default)((0, _wrapAsync2.default)(iteratee)), callback); | ||
| return (0, _eachOfLimit2.default)(limit)(coll, (0, _withoutIndex2.default)((0, _wrapAsync2.default)(iteratee)), callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(eachLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -185,2 +185,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(eachOf, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -43,6 +43,6 @@ | ||
| function eachOfLimit(coll, limit, iteratee, callback) { | ||
| return (0, _eachOfLimit3.default)(limit)(coll, (0, _wrapAsync2.default)(iteratee), callback); | ||
| return (0, _eachOfLimit3.default)(limit)(coll, (0, _wrapAsync2.default)(iteratee), callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(eachOfLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -36,5 +36,5 @@ | ||
| function eachOfSeries(coll, iteratee, callback) { | ||
| return (0, _eachOfLimit2.default)(coll, 1, iteratee, callback); | ||
| return (0, _eachOfLimit2.default)(coll, 1, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(eachOfSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -41,5 +41,5 @@ | ||
| function eachSeries(coll, iteratee, callback) { | ||
| return (0, _eachLimit2.default)(coll, 1, iteratee, callback); | ||
| return (0, _eachLimit2.default)(coll, 1, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(eachSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -68,2 +68,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(forever, 2); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -106,4 +106,4 @@ exports.default = groupBy; | ||
| function groupBy(coll, iteratee, callback) { | ||
| return (0, _groupByLimit2.default)(coll, Infinity, iteratee, callback); | ||
| return (0, _groupByLimit2.default)(coll, Infinity, iteratee, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -71,2 +71,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(groupByLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -34,4 +34,4 @@ exports.default = groupBySeries; | ||
| function groupBySeries(coll, iteratee, callback) { | ||
| return (0, _groupByLimit2.default)(coll, 1, iteratee, callback); | ||
| return (0, _groupByLimit2.default)(coll, 1, iteratee, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
210
index.js
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -380,107 +380,107 @@ exports.doDuring = exports.during = exports.wrapSync = undefined; | ||
| exports.default = { | ||
| apply: _apply2.default, | ||
| applyEach: _applyEach2.default, | ||
| applyEachSeries: _applyEachSeries2.default, | ||
| asyncify: _asyncify2.default, | ||
| auto: _auto2.default, | ||
| autoInject: _autoInject2.default, | ||
| cargo: _cargo2.default, | ||
| cargoQueue: _cargoQueue2.default, | ||
| compose: _compose2.default, | ||
| concat: _concat2.default, | ||
| concatLimit: _concatLimit2.default, | ||
| concatSeries: _concatSeries2.default, | ||
| constant: _constant2.default, | ||
| detect: _detect2.default, | ||
| detectLimit: _detectLimit2.default, | ||
| detectSeries: _detectSeries2.default, | ||
| dir: _dir2.default, | ||
| doUntil: _doUntil2.default, | ||
| doWhilst: _doWhilst2.default, | ||
| each: _each2.default, | ||
| eachLimit: _eachLimit2.default, | ||
| eachOf: _eachOf2.default, | ||
| eachOfLimit: _eachOfLimit2.default, | ||
| eachOfSeries: _eachOfSeries2.default, | ||
| eachSeries: _eachSeries2.default, | ||
| ensureAsync: _ensureAsync2.default, | ||
| every: _every2.default, | ||
| everyLimit: _everyLimit2.default, | ||
| everySeries: _everySeries2.default, | ||
| filter: _filter2.default, | ||
| filterLimit: _filterLimit2.default, | ||
| filterSeries: _filterSeries2.default, | ||
| forever: _forever2.default, | ||
| groupBy: _groupBy2.default, | ||
| groupByLimit: _groupByLimit2.default, | ||
| groupBySeries: _groupBySeries2.default, | ||
| log: _log2.default, | ||
| map: _map2.default, | ||
| mapLimit: _mapLimit2.default, | ||
| mapSeries: _mapSeries2.default, | ||
| mapValues: _mapValues2.default, | ||
| mapValuesLimit: _mapValuesLimit2.default, | ||
| mapValuesSeries: _mapValuesSeries2.default, | ||
| memoize: _memoize2.default, | ||
| nextTick: _nextTick2.default, | ||
| parallel: _parallel2.default, | ||
| parallelLimit: _parallelLimit2.default, | ||
| priorityQueue: _priorityQueue2.default, | ||
| queue: _queue2.default, | ||
| race: _race2.default, | ||
| reduce: _reduce2.default, | ||
| reduceRight: _reduceRight2.default, | ||
| reflect: _reflect2.default, | ||
| reflectAll: _reflectAll2.default, | ||
| reject: _reject2.default, | ||
| rejectLimit: _rejectLimit2.default, | ||
| rejectSeries: _rejectSeries2.default, | ||
| retry: _retry2.default, | ||
| retryable: _retryable2.default, | ||
| seq: _seq2.default, | ||
| series: _series2.default, | ||
| setImmediate: _setImmediate2.default, | ||
| some: _some2.default, | ||
| someLimit: _someLimit2.default, | ||
| someSeries: _someSeries2.default, | ||
| sortBy: _sortBy2.default, | ||
| timeout: _timeout2.default, | ||
| times: _times2.default, | ||
| timesLimit: _timesLimit2.default, | ||
| timesSeries: _timesSeries2.default, | ||
| transform: _transform2.default, | ||
| tryEach: _tryEach2.default, | ||
| unmemoize: _unmemoize2.default, | ||
| until: _until2.default, | ||
| waterfall: _waterfall2.default, | ||
| whilst: _whilst2.default, | ||
| apply: _apply2.default, | ||
| applyEach: _applyEach2.default, | ||
| applyEachSeries: _applyEachSeries2.default, | ||
| asyncify: _asyncify2.default, | ||
| auto: _auto2.default, | ||
| autoInject: _autoInject2.default, | ||
| cargo: _cargo2.default, | ||
| cargoQueue: _cargoQueue2.default, | ||
| compose: _compose2.default, | ||
| concat: _concat2.default, | ||
| concatLimit: _concatLimit2.default, | ||
| concatSeries: _concatSeries2.default, | ||
| constant: _constant2.default, | ||
| detect: _detect2.default, | ||
| detectLimit: _detectLimit2.default, | ||
| detectSeries: _detectSeries2.default, | ||
| dir: _dir2.default, | ||
| doUntil: _doUntil2.default, | ||
| doWhilst: _doWhilst2.default, | ||
| each: _each2.default, | ||
| eachLimit: _eachLimit2.default, | ||
| eachOf: _eachOf2.default, | ||
| eachOfLimit: _eachOfLimit2.default, | ||
| eachOfSeries: _eachOfSeries2.default, | ||
| eachSeries: _eachSeries2.default, | ||
| ensureAsync: _ensureAsync2.default, | ||
| every: _every2.default, | ||
| everyLimit: _everyLimit2.default, | ||
| everySeries: _everySeries2.default, | ||
| filter: _filter2.default, | ||
| filterLimit: _filterLimit2.default, | ||
| filterSeries: _filterSeries2.default, | ||
| forever: _forever2.default, | ||
| groupBy: _groupBy2.default, | ||
| groupByLimit: _groupByLimit2.default, | ||
| groupBySeries: _groupBySeries2.default, | ||
| log: _log2.default, | ||
| map: _map2.default, | ||
| mapLimit: _mapLimit2.default, | ||
| mapSeries: _mapSeries2.default, | ||
| mapValues: _mapValues2.default, | ||
| mapValuesLimit: _mapValuesLimit2.default, | ||
| mapValuesSeries: _mapValuesSeries2.default, | ||
| memoize: _memoize2.default, | ||
| nextTick: _nextTick2.default, | ||
| parallel: _parallel2.default, | ||
| parallelLimit: _parallelLimit2.default, | ||
| priorityQueue: _priorityQueue2.default, | ||
| queue: _queue2.default, | ||
| race: _race2.default, | ||
| reduce: _reduce2.default, | ||
| reduceRight: _reduceRight2.default, | ||
| reflect: _reflect2.default, | ||
| reflectAll: _reflectAll2.default, | ||
| reject: _reject2.default, | ||
| rejectLimit: _rejectLimit2.default, | ||
| rejectSeries: _rejectSeries2.default, | ||
| retry: _retry2.default, | ||
| retryable: _retryable2.default, | ||
| seq: _seq2.default, | ||
| series: _series2.default, | ||
| setImmediate: _setImmediate2.default, | ||
| some: _some2.default, | ||
| someLimit: _someLimit2.default, | ||
| someSeries: _someSeries2.default, | ||
| sortBy: _sortBy2.default, | ||
| timeout: _timeout2.default, | ||
| times: _times2.default, | ||
| timesLimit: _timesLimit2.default, | ||
| timesSeries: _timesSeries2.default, | ||
| transform: _transform2.default, | ||
| tryEach: _tryEach2.default, | ||
| unmemoize: _unmemoize2.default, | ||
| until: _until2.default, | ||
| waterfall: _waterfall2.default, | ||
| whilst: _whilst2.default, | ||
| // aliases | ||
| all: _every2.default, | ||
| allLimit: _everyLimit2.default, | ||
| allSeries: _everySeries2.default, | ||
| any: _some2.default, | ||
| anyLimit: _someLimit2.default, | ||
| anySeries: _someSeries2.default, | ||
| find: _detect2.default, | ||
| findLimit: _detectLimit2.default, | ||
| findSeries: _detectSeries2.default, | ||
| flatMap: _concat2.default, | ||
| flatMapLimit: _concatLimit2.default, | ||
| flatMapSeries: _concatSeries2.default, | ||
| forEach: _each2.default, | ||
| forEachSeries: _eachSeries2.default, | ||
| forEachLimit: _eachLimit2.default, | ||
| forEachOf: _eachOf2.default, | ||
| forEachOfSeries: _eachOfSeries2.default, | ||
| forEachOfLimit: _eachOfLimit2.default, | ||
| inject: _reduce2.default, | ||
| foldl: _reduce2.default, | ||
| foldr: _reduceRight2.default, | ||
| select: _filter2.default, | ||
| selectLimit: _filterLimit2.default, | ||
| selectSeries: _filterSeries2.default, | ||
| wrapSync: _asyncify2.default, | ||
| during: _whilst2.default, | ||
| doDuring: _doWhilst2.default | ||
| // aliases | ||
| all: _every2.default, | ||
| allLimit: _everyLimit2.default, | ||
| allSeries: _everySeries2.default, | ||
| any: _some2.default, | ||
| anyLimit: _someLimit2.default, | ||
| anySeries: _someSeries2.default, | ||
| find: _detect2.default, | ||
| findLimit: _detectLimit2.default, | ||
| findSeries: _detectSeries2.default, | ||
| flatMap: _concat2.default, | ||
| flatMapLimit: _concatLimit2.default, | ||
| flatMapSeries: _concatSeries2.default, | ||
| forEach: _each2.default, | ||
| forEachSeries: _eachSeries2.default, | ||
| forEachLimit: _eachLimit2.default, | ||
| forEachOf: _eachOf2.default, | ||
| forEachOfSeries: _eachOfSeries2.default, | ||
| forEachOfLimit: _eachOfLimit2.default, | ||
| inject: _reduce2.default, | ||
| foldl: _reduce2.default, | ||
| foldr: _reduceRight2.default, | ||
| select: _filter2.default, | ||
| selectLimit: _filterLimit2.default, | ||
| selectSeries: _filterSeries2.default, | ||
| wrapSync: _asyncify2.default, | ||
| during: _whilst2.default, | ||
| doDuring: _doWhilst2.default | ||
| }; | ||
@@ -487,0 +487,0 @@ exports.apply = _apply2.default; |
@@ -153,2 +153,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(reduce, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -29,2 +29,2 @@ 'use strict'; | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -75,2 +75,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -9,3 +9,4 @@ 'use strict'; | ||
| // only return a promise if a callback is omitted | ||
| function awaitify(asyncFn, arity = asyncFn.length) { | ||
| function awaitify(asyncFn, arity) { | ||
| if (!arity) arity = asyncFn.length; | ||
| if (!arity) throw new Error('arity is undefined'); | ||
@@ -28,2 +29,2 @@ function awaitable(...args) { | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -10,2 +10,2 @@ // A temporary value used to identify if the loop should be broken. | ||
| exports.default = breakLoop; | ||
| module.exports = exports["default"]; | ||
| module.exports = exports.default; |
@@ -31,2 +31,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -40,2 +40,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -92,2 +92,2 @@ "use strict"; | ||
| } | ||
| module.exports = exports["default"]; | ||
| module.exports = exports.default; |
@@ -90,2 +90,2 @@ 'use strict'; | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -55,2 +55,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -11,2 +11,2 @@ "use strict"; | ||
| module.exports = exports["default"]; | ||
| module.exports = exports.default; |
@@ -120,2 +120,2 @@ "use strict"; | ||
| } | ||
| module.exports = exports["default"]; | ||
| module.exports = exports.default; |
@@ -14,2 +14,2 @@ "use strict"; | ||
| module.exports = exports["default"]; | ||
| module.exports = exports.default; |
@@ -10,2 +10,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -57,2 +57,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -30,2 +30,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -17,2 +17,2 @@ "use strict"; | ||
| } | ||
| module.exports = exports["default"]; | ||
| module.exports = exports.default; |
@@ -15,2 +15,2 @@ "use strict"; | ||
| } | ||
| module.exports = exports["default"]; | ||
| module.exports = exports.default; |
@@ -34,2 +34,2 @@ 'use strict'; | ||
| }, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -294,2 +294,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -14,2 +14,2 @@ "use strict"; | ||
| } | ||
| module.exports = exports["default"]; | ||
| module.exports = exports.default; |
@@ -26,2 +26,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -10,2 +10,2 @@ "use strict"; | ||
| } | ||
| module.exports = exports["default"]; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -41,2 +41,2 @@ | ||
| exports.default = (0, _consoleFunc2.default)('log'); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -139,5 +139,5 @@ | ||
| function map(coll, iteratee, callback) { | ||
| return (0, _map3.default)(_eachOf2.default, coll, iteratee, callback); | ||
| return (0, _map3.default)(_eachOf2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(map, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -42,5 +42,5 @@ | ||
| function mapLimit(coll, limit, iteratee, callback) { | ||
| return (0, _map3.default)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| return (0, _map3.default)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(mapLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -41,5 +41,5 @@ | ||
| function mapSeries(coll, iteratee, callback) { | ||
| return (0, _map3.default)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| return (0, _map3.default)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(mapSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -150,4 +150,4 @@ exports.default = mapValues; | ||
| function mapValues(obj, iteratee, callback) { | ||
| return (0, _mapValuesLimit2.default)(obj, Infinity, iteratee, callback); | ||
| return (0, _mapValuesLimit2.default)(obj, Infinity, iteratee, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -61,2 +61,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(mapValuesLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -35,4 +35,4 @@ exports.default = mapValuesSeries; | ||
| function mapValuesSeries(obj, iteratee, callback) { | ||
| return (0, _mapValuesLimit2.default)(obj, 1, iteratee, callback); | ||
| return (0, _mapValuesLimit2.default)(obj, 1, iteratee, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -91,2 +91,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -52,2 +52,2 @@ 'use strict'; | ||
| exports.default = (0, _setImmediate.wrap)(_defer); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| { | ||
| "name": "async", | ||
| "description": "Higher-order functions and common patterns for asynchronous code", | ||
| "version": "3.2.4", | ||
| "version": "3.2.5", | ||
| "main": "dist/async.js", | ||
@@ -23,3 +23,3 @@ "author": "Caolan McMahon", | ||
| "@babel/eslint-parser": "^7.16.5", | ||
| "babel-core": "^6.26.3", | ||
| "@babel/core": "7.23.2", | ||
| "babel-minify": "^0.5.0", | ||
@@ -42,3 +42,3 @@ "babel-plugin-add-module-exports": "^1.0.4", | ||
| "eslint-plugin-prefer-arrow": "^1.2.3", | ||
| "fs-extra": "^10.0.0", | ||
| "fs-extra": "^11.1.1", | ||
| "jsdoc": "^3.6.2", | ||
@@ -54,3 +54,3 @@ "karma": "^6.3.12", | ||
| "nyc": "^15.1.0", | ||
| "rollup": "^2.66.1", | ||
| "rollup": "^4.2.0", | ||
| "rollup-plugin-node-resolve": "^5.2.0", | ||
@@ -57,0 +57,0 @@ "rollup-plugin-npm": "^2.0.0", |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -178,4 +178,4 @@ exports.default = parallel; | ||
| function parallel(tasks, callback) { | ||
| return (0, _parallel3.default)(_eachOf2.default, tasks, callback); | ||
| return (0, _parallel3.default)(_eachOf2.default, tasks, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -39,4 +39,4 @@ exports.default = parallelLimit; | ||
| function parallelLimit(tasks, limit, callback) { | ||
| return (0, _parallel2.default)((0, _eachOfLimit2.default)(limit), tasks, callback); | ||
| return (0, _parallel2.default)((0, _eachOfLimit2.default)(limit), tasks, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -60,28 +60,2 @@ 'use strict'; | ||
| module.exports = exports['default']; | ||
| /** | ||
| * The same as [async.queue]{@link module:ControlFlow.queue} only tasks are assigned a priority and | ||
| * completed in ascending priority order. | ||
| * | ||
| * @name priorityQueue | ||
| * @static | ||
| * @memberOf module:ControlFlow | ||
| * @method | ||
| * @see [async.queue]{@link module:ControlFlow.queue} | ||
| * @category Control Flow | ||
| * @param {AsyncFunction} worker - An async function for processing a queued task. | ||
| * If you want to handle errors from an individual task, pass a callback to | ||
| * `q.push()`. | ||
| * Invoked with (task, callback). | ||
| * @param {number} concurrency - An `integer` for determining how many `worker` | ||
| * functions should be run in parallel. If omitted, the concurrency defaults to | ||
| * `1`. If the concurrency is `0`, an error is thrown. | ||
| * @returns {module:ControlFlow.QueueObject} A priorityQueue object to manage the tasks. There are three | ||
| * differences between `queue` and `priorityQueue` objects: | ||
| * * `push(task, priority, [callback])` - `priority` should be a number. If an | ||
| * array of `tasks` is given, all tasks will be assigned the same priority. | ||
| * * `pushAsync(task, priority, [callback])` - the same as `priorityQueue.push`, | ||
| * except this returns a promise that rejects if an error occurs. | ||
| * * The `unshift` and `unshiftAsync` methods were removed. | ||
| */ | ||
| module.exports = exports.default; |
155
queue.js
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
| exports.default = function (worker, concurrency) { | ||
| var _worker = (0, _wrapAsync2.default)(worker); | ||
| return (0, _queue2.default)((items, cb) => { | ||
| _worker(items[0], cb); | ||
| }, concurrency, 1); | ||
| var _worker = (0, _wrapAsync2.default)(worker); | ||
| return (0, _queue2.default)((items, cb) => { | ||
| _worker(items[0], cb); | ||
| }, concurrency, 1); | ||
| }; | ||
@@ -24,145 +24,2 @@ | ||
| module.exports = exports['default']; | ||
| /** | ||
| * A queue of tasks for the worker function to complete. | ||
| * @typedef {Iterable} QueueObject | ||
| * @memberOf module:ControlFlow | ||
| * @property {Function} length - a function returning the number of items | ||
| * waiting to be processed. Invoke with `queue.length()`. | ||
| * @property {boolean} started - a boolean indicating whether or not any | ||
| * items have been pushed and processed by the queue. | ||
| * @property {Function} running - a function returning the number of items | ||
| * currently being processed. Invoke with `queue.running()`. | ||
| * @property {Function} workersList - a function returning the array of items | ||
| * currently being processed. Invoke with `queue.workersList()`. | ||
| * @property {Function} idle - a function returning false if there are items | ||
| * waiting or being processed, or true if not. Invoke with `queue.idle()`. | ||
| * @property {number} concurrency - an integer for determining how many `worker` | ||
| * functions should be run in parallel. This property can be changed after a | ||
| * `queue` is created to alter the concurrency on-the-fly. | ||
| * @property {number} payload - an integer that specifies how many items are | ||
| * passed to the worker function at a time. only applies if this is a | ||
| * [cargo]{@link module:ControlFlow.cargo} object | ||
| * @property {AsyncFunction} push - add a new task to the `queue`. Calls `callback` | ||
| * once the `worker` has finished processing the task. Instead of a single task, | ||
| * a `tasks` array can be submitted. The respective callback is used for every | ||
| * task in the list. Invoke with `queue.push(task, [callback])`, | ||
| * @property {AsyncFunction} unshift - add a new task to the front of the `queue`. | ||
| * Invoke with `queue.unshift(task, [callback])`. | ||
| * @property {AsyncFunction} pushAsync - the same as `q.push`, except this returns | ||
| * a promise that rejects if an error occurs. | ||
| * @property {AsyncFunction} unshiftAsync - the same as `q.unshift`, except this returns | ||
| * a promise that rejects if an error occurs. | ||
| * @property {Function} remove - remove items from the queue that match a test | ||
| * function. The test function will be passed an object with a `data` property, | ||
| * and a `priority` property, if this is a | ||
| * [priorityQueue]{@link module:ControlFlow.priorityQueue} object. | ||
| * Invoked with `queue.remove(testFn)`, where `testFn` is of the form | ||
| * `function ({data, priority}) {}` and returns a Boolean. | ||
| * @property {Function} saturated - a function that sets a callback that is | ||
| * called when the number of running workers hits the `concurrency` limit, and | ||
| * further tasks will be queued. If the callback is omitted, `q.saturated()` | ||
| * returns a promise for the next occurrence. | ||
| * @property {Function} unsaturated - a function that sets a callback that is | ||
| * called when the number of running workers is less than the `concurrency` & | ||
| * `buffer` limits, and further tasks will not be queued. If the callback is | ||
| * omitted, `q.unsaturated()` returns a promise for the next occurrence. | ||
| * @property {number} buffer - A minimum threshold buffer in order to say that | ||
| * the `queue` is `unsaturated`. | ||
| * @property {Function} empty - a function that sets a callback that is called | ||
| * when the last item from the `queue` is given to a `worker`. If the callback | ||
| * is omitted, `q.empty()` returns a promise for the next occurrence. | ||
| * @property {Function} drain - a function that sets a callback that is called | ||
| * when the last item from the `queue` has returned from the `worker`. If the | ||
| * callback is omitted, `q.drain()` returns a promise for the next occurrence. | ||
| * @property {Function} error - a function that sets a callback that is called | ||
| * when a task errors. Has the signature `function(error, task)`. If the | ||
| * callback is omitted, `error()` returns a promise that rejects on the next | ||
| * error. | ||
| * @property {boolean} paused - a boolean for determining whether the queue is | ||
| * in a paused state. | ||
| * @property {Function} pause - a function that pauses the processing of tasks | ||
| * until `resume()` is called. Invoke with `queue.pause()`. | ||
| * @property {Function} resume - a function that resumes the processing of | ||
| * queued tasks when the queue is paused. Invoke with `queue.resume()`. | ||
| * @property {Function} kill - a function that removes the `drain` callback and | ||
| * empties remaining tasks from the queue forcing it to go idle. No more tasks | ||
| * should be pushed to the queue after calling this function. Invoke with `queue.kill()`. | ||
| * | ||
| * @example | ||
| * const q = async.queue(worker, 2) | ||
| * q.push(item1) | ||
| * q.push(item2) | ||
| * q.push(item3) | ||
| * // queues are iterable, spread into an array to inspect | ||
| * const items = [...q] // [item1, item2, item3] | ||
| * // or use for of | ||
| * for (let item of q) { | ||
| * console.log(item) | ||
| * } | ||
| * | ||
| * q.drain(() => { | ||
| * console.log('all done') | ||
| * }) | ||
| * // or | ||
| * await q.drain() | ||
| */ | ||
| /** | ||
| * Creates a `queue` object with the specified `concurrency`. Tasks added to the | ||
| * `queue` are processed in parallel (up to the `concurrency` limit). If all | ||
| * `worker`s are in progress, the task is queued until one becomes available. | ||
| * Once a `worker` completes a `task`, that `task`'s callback is called. | ||
| * | ||
| * @name queue | ||
| * @static | ||
| * @memberOf module:ControlFlow | ||
| * @method | ||
| * @category Control Flow | ||
| * @param {AsyncFunction} worker - An async function for processing a queued task. | ||
| * If you want to handle errors from an individual task, pass a callback to | ||
| * `q.push()`. Invoked with (task, callback). | ||
| * @param {number} [concurrency=1] - An `integer` for determining how many | ||
| * `worker` functions should be run in parallel. If omitted, the concurrency | ||
| * defaults to `1`. If the concurrency is `0`, an error is thrown. | ||
| * @returns {module:ControlFlow.QueueObject} A queue object to manage the tasks. Callbacks can be | ||
| * attached as certain properties to listen for specific events during the | ||
| * lifecycle of the queue. | ||
| * @example | ||
| * | ||
| * // create a queue object with concurrency 2 | ||
| * var q = async.queue(function(task, callback) { | ||
| * console.log('hello ' + task.name); | ||
| * callback(); | ||
| * }, 2); | ||
| * | ||
| * // assign a callback | ||
| * q.drain(function() { | ||
| * console.log('all items have been processed'); | ||
| * }); | ||
| * // or await the end | ||
| * await q.drain() | ||
| * | ||
| * // assign an error callback | ||
| * q.error(function(err, task) { | ||
| * console.error('task experienced an error'); | ||
| * }); | ||
| * | ||
| * // add some items to the queue | ||
| * q.push({name: 'foo'}, function(err) { | ||
| * console.log('finished processing foo'); | ||
| * }); | ||
| * // callback is optional | ||
| * q.push({name: 'bar'}); | ||
| * | ||
| * // add some items to the queue (batch-wise) | ||
| * q.push([{name: 'baz'},{name: 'bay'},{name: 'bax'}], function(err) { | ||
| * console.log('finished processing item'); | ||
| * }); | ||
| * | ||
| * // add some items to the front of the queue | ||
| * q.unshift({name: 'bar'}, function (err) { | ||
| * console.log('finished processing bar'); | ||
| * }); | ||
| */ | ||
| module.exports = exports.default; |
@@ -67,2 +67,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(race, 2); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -153,2 +153,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(reduce, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -38,5 +38,5 @@ exports.default = reduceRight; | ||
| function reduceRight(array, memo, iteratee, callback) { | ||
| var reversed = [...array].reverse(); | ||
| return (0, _reduce2.default)(reversed, memo, iteratee, callback); | ||
| var reversed = [...array].reverse(); | ||
| return (0, _reduce2.default)(reversed, memo, iteratee, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -78,2 +78,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -93,2 +93,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -84,5 +84,5 @@ | ||
| function reject(coll, iteratee, callback) { | ||
| return (0, _reject3.default)(_eachOf2.default, coll, iteratee, callback); | ||
| return (0, _reject3.default)(_eachOf2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(reject, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -42,5 +42,5 @@ | ||
| function rejectLimit(coll, limit, iteratee, callback) { | ||
| return (0, _reject3.default)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| return (0, _reject3.default)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(rejectLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -40,5 +40,5 @@ | ||
| function rejectSeries(coll, iteratee, callback) { | ||
| return (0, _reject3.default)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| return (0, _reject3.default)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(rejectSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -159,2 +159,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -77,2 +77,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -90,5 +90,5 @@ | ||
| function filter(coll, iteratee, callback) { | ||
| return (0, _filter3.default)(_eachOf2.default, coll, iteratee, callback); | ||
| return (0, _filter3.default)(_eachOf2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(filter, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -42,5 +42,5 @@ | ||
| function filterLimit(coll, limit, iteratee, callback) { | ||
| return (0, _filter3.default)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| return (0, _filter3.default)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(filterLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -40,5 +40,5 @@ | ||
| function filterSeries(coll, iteratee, callback) { | ||
| return (0, _filter3.default)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| return (0, _filter3.default)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(filterSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -79,2 +79,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -184,4 +184,4 @@ exports.default = series; | ||
| function series(tasks, callback) { | ||
| return (0, _parallel3.default)(_eachOfSeries2.default, tasks, callback); | ||
| return (0, _parallel3.default)(_eachOfSeries2.default, tasks, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -45,2 +45,2 @@ | ||
| exports.default = _setImmediate2.default; | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -119,5 +119,5 @@ | ||
| function some(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(Boolean, res => res)(_eachOf2.default, coll, iteratee, callback); | ||
| return (0, _createTester2.default)(Boolean, res => res)(_eachOf2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(some, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -44,5 +44,5 @@ | ||
| function someLimit(coll, limit, iteratee, callback) { | ||
| return (0, _createTester2.default)(Boolean, res => res)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| return (0, _createTester2.default)(Boolean, res => res)((0, _eachOfLimit2.default)(limit), coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(someLimit, 4); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -43,5 +43,5 @@ | ||
| function someSeries(coll, iteratee, callback) { | ||
| return (0, _createTester2.default)(Boolean, res => res)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| return (0, _createTester2.default)(Boolean, res => res)(_eachOfSeries2.default, coll, iteratee, callback); | ||
| } | ||
| exports.default = (0, _awaitify2.default)(someSeries, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -190,2 +190,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(sortBy, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -89,2 +89,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -48,4 +48,4 @@ exports.default = times; | ||
| function times(n, iteratee, callback) { | ||
| return (0, _timesLimit2.default)(n, Infinity, iteratee, callback); | ||
| return (0, _timesLimit2.default)(n, Infinity, iteratee, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -40,5 +40,5 @@ exports.default = timesLimit; | ||
| function timesLimit(count, limit, iteratee, callback) { | ||
| var _iteratee = (0, _wrapAsync2.default)(iteratee); | ||
| return (0, _mapLimit2.default)((0, _range2.default)(count), limit, _iteratee, callback); | ||
| var _iteratee = (0, _wrapAsync2.default)(iteratee); | ||
| return (0, _mapLimit2.default)((0, _range2.default)(count), limit, _iteratee, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -30,4 +30,4 @@ exports.default = timesSeries; | ||
| function timesSeries(n, iteratee, callback) { | ||
| return (0, _timesLimit2.default)(n, 1, iteratee, callback); | ||
| return (0, _timesLimit2.default)(n, 1, iteratee, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -173,2 +173,2 @@ 'use strict'; | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -78,2 +78,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(tryEach); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -25,2 +25,2 @@ "use strict"; | ||
| } | ||
| module.exports = exports["default"]; | ||
| module.exports = exports.default; |
| 'use strict'; | ||
| Object.defineProperty(exports, "__esModule", { | ||
| value: true | ||
| value: true | ||
| }); | ||
@@ -58,5 +58,5 @@ exports.default = until; | ||
| function until(test, iteratee, callback) { | ||
| const _test = (0, _wrapAsync2.default)(test); | ||
| return (0, _whilst2.default)(cb => _test((err, truth) => cb(err, !truth)), iteratee, callback); | ||
| const _test = (0, _wrapAsync2.default)(test); | ||
| return (0, _whilst2.default)(cb => _test((err, truth) => cb(err, !truth)), iteratee, callback); | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -105,2 +105,2 @@ 'use strict'; | ||
| exports.default = (0, _awaitify2.default)(waterfall); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -31,3 +31,3 @@ 'use strict'; | ||
| * @param {AsyncFunction} test - asynchronous truth test to perform before each | ||
| * execution of `iteratee`. Invoked with (). | ||
| * execution of `iteratee`. Invoked with (callback). | ||
| * @param {AsyncFunction} iteratee - An async function which is called each time | ||
@@ -79,2 +79,2 @@ * `test` passes. Invoked with (callback). | ||
| exports.default = (0, _awaitify2.default)(whilst, 3); | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
@@ -105,3 +105,3 @@ 'use strict'; | ||
| }, err => { | ||
| invokeCallback(callback, err && err.message ? err : new Error(err)); | ||
| invokeCallback(callback, err && (err instanceof Error || err.message) ? err : new Error(err)); | ||
| }); | ||
@@ -119,2 +119,2 @@ } | ||
| } | ||
| module.exports = exports['default']; | ||
| module.exports = exports.default; |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
No alert changes
Worsened metrics
- Total package byte prevSize
- decreased by-1.58%
807668
- Lines of code
- decreased by-1.23%
19908
No dependency changes