async
Advanced tools
Comparing version 3.2.0 to 3.2.1
77
all.js
@@ -42,9 +42,74 @@ 'use strict'; | ||
| * | ||
| * async.every(['file1','file2','file3'], function(filePath, callback) { | ||
| * fs.access(filePath, function(err) { | ||
| * callback(null, !err) | ||
| * }); | ||
| * }, function(err, result) { | ||
| * // if result is true then every file exists | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * // dir4 does not exist | ||
| * | ||
| * const fileList = ['dir1/file1.txt','dir2/file3.txt','dir3/file5.txt']; | ||
| * const withMissingFileList = ['file1.txt','file2.txt','file4.txt']; | ||
| * | ||
| * // asynchronous function that checks if a file exists | ||
| * function fileExists(file, callback) { | ||
| * fs.access(file, fs.constants.F_OK, (err) => { | ||
| * callback(null, !err); | ||
| * }); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.every(fileList, fileExists, function(err, result) { | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since every file exists | ||
| * }); | ||
| * | ||
| * async.every(withMissingFileList, fileExists, function(err, result) { | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since NOT every file exists | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.every(fileList, fileExists) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since every file exists | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * async.every(withMissingFileList, fileExists) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since NOT every file exists | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.every(fileList, fileExists); | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since every file exists | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.every(withMissingFileList, fileExists); | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since NOT every file exists | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -51,0 +116,0 @@ function every(coll, iteratee, callback) { |
78
any.js
@@ -44,9 +44,75 @@ 'use strict'; | ||
| * | ||
| * async.some(['file1','file2','file3'], function(filePath, callback) { | ||
| * fs.access(filePath, function(err) { | ||
| * callback(null, !err) | ||
| * }); | ||
| * }, function(err, result) { | ||
| * // if result is true then at least one of the files exists | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * // dir4 does not exist | ||
| * | ||
| * // asynchronous function that checks if a file exists | ||
| * function fileExists(file, callback) { | ||
| * fs.access(file, fs.constants.F_OK, (err) => { | ||
| * callback(null, !err); | ||
| * }); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.some(['dir1/missing.txt','dir2/missing.txt','dir3/file5.txt'], fileExists, | ||
| * function(err, result) { | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since some file in the list exists | ||
| * } | ||
| *); | ||
| * | ||
| * async.some(['dir1/missing.txt','dir2/missing.txt','dir4/missing.txt'], fileExists, | ||
| * function(err, result) { | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since none of the files exists | ||
| * } | ||
| *); | ||
| * | ||
| * // Using Promises | ||
| * async.some(['dir1/missing.txt','dir2/missing.txt','dir3/file5.txt'], fileExists) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since some file in the list exists | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * async.some(['dir1/missing.txt','dir2/missing.txt','dir4/missing.txt'], fileExists) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since none of the files exists | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.some(['dir1/missing.txt','dir2/missing.txt','dir3/file5.txt'], fileExists); | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since some file in the list exists | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.some(['dir1/missing.txt','dir2/missing.txt','dir4/missing.txt'], fileExists); | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since none of the files exists | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -53,0 +119,0 @@ function some(coll, iteratee, callback) { |
88
auto.js
@@ -65,11 +65,36 @@ 'use strict'; | ||
| * | ||
| * //Using Callbacks | ||
| * async.auto({ | ||
| * // this function will just be passed a callback | ||
| * readData: async.apply(fs.readFile, 'data.txt', 'utf-8'), | ||
| * showData: ['readData', function(results, cb) { | ||
| * // results.readData is the file's contents | ||
| * // ... | ||
| * get_data: function(callback) { | ||
| * // async code to get some data | ||
| * callback(null, 'data', 'converted to array'); | ||
| * }, | ||
| * make_folder: function(callback) { | ||
| * // async code to create a directory to store a file in | ||
| * // this is run at the same time as getting the data | ||
| * callback(null, 'folder'); | ||
| * }, | ||
| * write_file: ['get_data', 'make_folder', function(results, callback) { | ||
| * // once there is some data and the directory exists, | ||
| * // write the data to a file in the directory | ||
| * callback(null, 'filename'); | ||
| * }], | ||
| * email_link: ['write_file', function(results, callback) { | ||
| * // once the file is written let's email a link to it... | ||
| * callback(null, {'file':results.write_file, 'email':'user@example.com'}); | ||
| * }] | ||
| * }, callback); | ||
| * }, function(err, results) { | ||
| * if (err) { | ||
| * console.log('err = ', err); | ||
| * } | ||
| * console.log('results = ', results); | ||
| * // results = { | ||
| * // get_data: ['data', 'converted to array'] | ||
| * // make_folder; 'folder', | ||
| * // write_file: 'filename' | ||
| * // email_link: { file: 'filename', email: 'user@example.com' } | ||
| * // } | ||
| * }); | ||
| * | ||
| * //Using Promises | ||
| * async.auto({ | ||
@@ -88,3 +113,2 @@ * get_data: function(callback) { | ||
| * write_file: ['get_data', 'make_folder', function(results, callback) { | ||
| * console.log('in write_file', JSON.stringify(results)); | ||
| * // once there is some data and the directory exists, | ||
@@ -95,11 +119,53 @@ * // write the data to a file in the directory | ||
| * email_link: ['write_file', function(results, callback) { | ||
| * console.log('in email_link', JSON.stringify(results)); | ||
| * // once the file is written let's email a link to it... | ||
| * // results.write_file contains the filename returned by write_file. | ||
| * callback(null, {'file':results.write_file, 'email':'user@example.com'}); | ||
| * }] | ||
| * }, function(err, results) { | ||
| * }).then(results => { | ||
| * console.log('results = ', results); | ||
| * // results = { | ||
| * // get_data: ['data', 'converted to array'] | ||
| * // make_folder; 'folder', | ||
| * // write_file: 'filename' | ||
| * // email_link: { file: 'filename', email: 'user@example.com' } | ||
| * // } | ||
| * }).catch(err => { | ||
| * console.log('err = ', err); | ||
| * console.log('results = ', results); | ||
| * }); | ||
| * | ||
| * //Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.auto({ | ||
| * get_data: function(callback) { | ||
| * // async code to get some data | ||
| * callback(null, 'data', 'converted to array'); | ||
| * }, | ||
| * make_folder: function(callback) { | ||
| * // async code to create a directory to store a file in | ||
| * // this is run at the same time as getting the data | ||
| * callback(null, 'folder'); | ||
| * }, | ||
| * write_file: ['get_data', 'make_folder', function(results, callback) { | ||
| * // once there is some data and the directory exists, | ||
| * // write the data to a file in the directory | ||
| * callback(null, 'filename'); | ||
| * }], | ||
| * email_link: ['write_file', function(results, callback) { | ||
| * // once the file is written let's email a link to it... | ||
| * callback(null, {'file':results.write_file, 'email':'user@example.com'}); | ||
| * }] | ||
| * }); | ||
| * console.log('results = ', results); | ||
| * // results = { | ||
| * // get_data: ['data', 'converted to array'] | ||
| * // make_folder; 'folder', | ||
| * // write_file: 'filename' | ||
| * // email_link: { file: 'filename', email: 'user@example.com' } | ||
| * // } | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -106,0 +172,0 @@ function auto(tasks, concurrency, callback) { |
@@ -39,5 +39,73 @@ 'use strict'; | ||
| * | ||
| * async.concat(['dir1','dir2','dir3'], fs.readdir, function(err, files) { | ||
| * // files is now a list of filenames that exist in the 3 directories | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * // dir4 does not exist | ||
| * | ||
| * let directoryList = ['dir1','dir2','dir3']; | ||
| * let withMissingDirectoryList = ['dir1','dir2','dir3', 'dir4']; | ||
| * | ||
| * // Using callbacks | ||
| * async.concat(directoryList, fs.readdir, function(err, results) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(results); | ||
| * // [ 'file1.txt', 'file2.txt', 'file3.txt', 'file4.txt', file5.txt ] | ||
| * } | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.concat(withMissingDirectoryList, fs.readdir, function(err, results) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4 does not exist | ||
| * } else { | ||
| * console.log(results); | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.concat(directoryList, fs.readdir) | ||
| * .then(results => { | ||
| * console.log(results); | ||
| * // [ 'file1.txt', 'file2.txt', 'file3.txt', 'file4.txt', file5.txt ] | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.concat(withMissingDirectoryList, fs.readdir) | ||
| * .then(results => { | ||
| * console.log(results); | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4 does not exist | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.concat(directoryList, fs.readdir); | ||
| * console.log(results); | ||
| * // [ 'file1.txt', 'file2.txt', 'file3.txt', 'file4.txt', file5.txt ] | ||
| * } catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * // Error Handling | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.concat(withMissingDirectoryList, fs.readdir); | ||
| * console.log(results); | ||
| * } catch (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4 does not exist | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -44,0 +112,0 @@ function concat(coll, iteratee, callback) { |
@@ -49,9 +49,44 @@ 'use strict'; | ||
| * | ||
| * async.detect(['file1','file2','file3'], function(filePath, callback) { | ||
| * fs.access(filePath, function(err) { | ||
| * callback(null, !err) | ||
| * }); | ||
| * }, function(err, result) { | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * | ||
| * // asynchronous function that checks if a file exists | ||
| * function fileExists(file, callback) { | ||
| * fs.access(file, fs.constants.F_OK, (err) => { | ||
| * callback(null, !err); | ||
| * }); | ||
| * } | ||
| * | ||
| * async.detect(['file3.txt','file2.txt','dir1/file1.txt'], fileExists, | ||
| * function(err, result) { | ||
| * console.log(result); | ||
| * // dir1/file1.txt | ||
| * // result now equals the first file in the list that exists | ||
| * } | ||
| *); | ||
| * | ||
| * // Using Promises | ||
| * async.detect(['file3.txt','file2.txt','dir1/file1.txt'], fileExists) | ||
| * .then(result => { | ||
| * console.log(result); | ||
| * // dir1/file1.txt | ||
| * // result now equals the first file in the list that exists | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.detect(['file3.txt','file2.txt','dir1/file1.txt'], fileExists); | ||
| * console.log(result); | ||
| * // dir1/file1.txt | ||
| * // result now equals the file in the list that exists | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -58,0 +93,0 @@ function detect(coll, iteratee, callback) { |
@@ -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(...a)=>e(...t,...a)}function a(e){return function(...t){var a=t.pop();return e.call(this,t,a)}}function n(e){setTimeout(e,0)}function i(e){return(t,...a)=>e(()=>t(...a))}function r(e){return u(e)?function(...t){const a=t.pop(),n=e.apply(this,t);return s(n,a)}:a(function(t,a){var n;try{n=e.apply(this,t)}catch(t){return a(t)}return n&&"function"==typeof n.then?s(n,a):void a(null,n)})}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,a){try{e(t,a)}catch(e){Ee(t=>{throw t},e)}}function u(e){return"AsyncFunction"===e[Symbol.toStringTag]}function c(e){return"AsyncGenerator"===e[Symbol.toStringTag]}function p(e){return"function"==typeof e[Symbol.asyncIterator]}function d(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(...a){return"function"==typeof a[t-1]?e.apply(this,a):new Promise((n,i)=>{a[t-1]=(e,...t)=>e?i(e):void n(1<t.length?t:t[0]),e.apply(this,a)})}}function h(e){return function(t,...a){const n=o(function(n){var i=this;return e(t,(e,t)=>{d(e).apply(i,a.concat(t))},n)});return n}}function f(e,t,a,n){t=t||[];var i=[],r=0,s=d(a);return e(t,(e,t,a)=>{var n=r++;s(e,(e,t)=>{i[n]=t,a(e)})},e=>{n(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 a=e;e=null,a.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,a=e.length;return function(){return++t<a?{value:e[t],key:t}:null}}function v(e){var t=-1;return function(){var a=e.next();return a.done?null:(t++,{value:a.value,key:t})}}function S(e){var t=e?Object.keys(e):[],a=-1,n=t.length;return function(){var i=t[++a];return a<n?{value:e[i],key:i}:null}}function L(e){if(y(e))return k(e);var t=g(e);return t?v(t):S(e)}function x(e){return function(...t){if(null===e)throw new Error("Callback was already called.");var a=e;e=null,a.apply(this,t)}}function E(e,t,a,n){function i(){p>=t||c||l||(c=!0,e.next().then(({value:e,done:t})=>{if(!(u||l))return c=!1,t?(l=!0,void(0>=p&&n(null))):void(p++,a(e,d,r),d++,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,n(null)):void i()}function s(e){u||(c=!1,l=!0,n(e))}let l=!1,u=!1,c=!1,p=0,d=0;i()}function b(e,t,a){function n(e,t){!1===e&&(l=!0);!0===l||(e?a(e):(++r===s||t===be)&&a(null))}a=m(a);var i=0,r=0,{length:s}=e,l=!1;for(0===s&&a(null);i<s;i++)t(e[i],i,x(n))}function O(e,t,a){return _e(e,1/0,t,a)}function _(){function e(e,...n){return e?a(e):void t(1<n.length?n:n[0])}let t,a;return e[Fe]=new Promise((e,n)=>{t=e,a=n}),e}function M(e,t,a){function n(e,t){g.push(()=>l(e,t))}function i(){if(!h){if(0===g.length&&0===o)return a(null,p);for(;g.length&&o<t;){var e=g.shift();e()}}}function r(e,t){var a=y[e];a||(a=y[e]=[]),a.push(t)}function s(e){var t=y[e]||[];t.forEach(e=>e()),i()}function l(e,t){if(!f){var n=x((t,...n)=>{if(o--,!1===t)return void(h=!0);if(2>n.length&&([n]=n),t){var i={};if(Object.keys(p).forEach(e=>{i[e]=p[e]}),i[e]=n,f=!0,y=Object.create(null),h)return;a(t,i)}else p[e]=n,s(e)});o++;var i=d(t[t.length-1]);1<t.length?i(p,n):i(n)}}function u(t){var a=[];return Object.keys(e).forEach(n=>{const i=e[n];Array.isArray(i)&&0<=i.indexOf(t)&&a.push(n)}),a}"number"!=typeof t&&(a=t,t=null),a=m(a||_());var c=Object.keys(e).length;if(!c)return a(null);t||(t=c);var p={},o=0,h=!1,f=!1,y=Object.create(null),g=[],k=[],v={};return Object.keys(e).forEach(t=>{var a=e[t];if(!Array.isArray(a))return n(t,[a]),void k.push(t);var i=a.slice(0,a.length-1),s=i.length;return 0===s?(n(t,a),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&&n(t,a)})}))}),function(){for(var e,t=0;k.length;)e=k.pop(),t++,u(e).forEach(e=>{0==--v[e]&&k.push(e)});if(t!==c)throw new Error("async.auto cannot execute tasks due to a recursive dependency")}(),i(),a[Fe]}function A(e){const t=e.toString().replace(ze,"");let a=t.match(Te);if(a||(a=t.match(Ce)),!a)throw new Error("could not parse args in autoInject\nSource:\n"+t);let[,n]=a;return n.replace(/\s/g,"").split(Pe).map(e=>e.replace(Re,"").trim())}function I(e,t){var a={};return Object.keys(e).forEach(t=>{function n(e,t){var a=i.map(t=>e[t]);a.push(t),d(r)(...a)}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(),a[t]=i.concat(0<i.length?n:r);else if(l)a[t]=r;else{if(i=A(r),0===r.length&&!s&&0===i.length)throw new Error("autoInject task functions require explicit parameters.");s||i.pop(),a[t]=i.concat(n)}}),M(a,t)}function j(e,t){e.length=1,e.head=e.tail=t}function w(e,t,a){function n(e,t){f[e].push(t)}function i(e,t){const a=(...n)=>{r(e,a),t(...n)};f[e].push(a)}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,a,n){function i(e,...t){return e?a?s(e):r():1>=t.length?r(t[0]):void r(t)}if(null!=n&&"function"!=typeof n)throw new Error("task callback must be a function");k.started=!0;var r,s,l={data:e,callback:a?i:n||i};if(t?k._tasks.unshift(l):k._tasks.push(l),y||(y=!0,Ee(()=>{y=!1,k.process()})),a||!n)return new Promise((e,t)=>{r=e,s=t})}function u(e){return function(t,...a){o-=1;for(var n=0,r=e.length;n<r;n++){var l=e[n],u=h.indexOf(l);0===u?h.shift():0<u&&h.splice(u,1),l.callback(t,...a),null!=t&&s("error",t,l.data)}o<=k.concurrency-k.buffer&&s("unsaturated"),k.idle()&&s("drain"),k.process()}}function c(e){return!!(0===e.length&&k.idle())&&(Ee(()=>s("drain")),!0)}if(null==t)t=1;else if(0===t)throw new RangeError("Concurrency must not be zero");var p=d(e),o=0,h=[];const f={error:[],drain:[],saturated:[],unsaturated:[],empty:[]};var y=!1;const m=e=>t=>t?void(r(e),n(e,t)):new Promise((t,a)=>{i(e,(e,n)=>e?a(e):void t(n))});var g=!1,k={_tasks:new Ne,*[Symbol.iterator](){yield*k._tasks[Symbol.iterator]()},concurrency:t,payload:a,buffer:t/4,started:!1,paused:!1,push(e,t){return Array.isArray(e)?c(e)?void 0:e.map(e=>l(e,!1,!1,t)):l(e,!1,!1,t)},pushAsync(e,t){return Array.isArray(e)?c(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)?c(e)?void 0:e.map(e=>l(e,!0,!1,t)):l(e,!0,!1,t)},unshiftAsync(e,t){return Array.isArray(e)?c(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=[],a=[],n=k._tasks.length;k.payload&&(n=e(n,k.payload));for(var r,c=0;c<n;c++)r=k._tasks.shift(),t.push(r),h.push(r),a.push(r.data);o+=1,0===k._tasks.length&&s("empty"),o===k.concurrency&&s("saturated");var d=x(u(t));p(a,d)}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,Ee(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 B(e,t){return w(e,1,t)}function F(e,t,a){return w(e,t,a)}function T(...e){var t=e.map(d);return function(...e){var a=this,n=e[e.length-1];return"function"==typeof n?e.pop():n=_(),Ye(t,e,(e,t,n)=>{t.apply(a,e.concat((e,...t)=>{n(e,t)}))},(e,t)=>n(e,...t)),n[Fe]}}function C(...e){return T(...e.reverse())}function P(...e){return function(...t){var a=t.pop();return a(null,...e)}}function R(e,t){return(a,n,i,r)=>{var s,l=!1;const u=d(i);a(n,(a,n,i)=>{u(a,(n,r)=>n||!1===n?i(n):e(r)&&!s?(l=!0,s=t(!0,a),i(null,be)):void i())},e=>e?r(e):void r(null,l?s:t(!1)))}}function z(e){return(t,...a)=>d(t)(...a,(t,...a)=>{"object"==typeof console&&(t?console.error&&console.error(t):console[e]&&a.forEach(t=>console[e](t)))})}function N(e,t,a){const n=d(t);return Ke(e,(...e)=>{const t=e.pop();n(...e,(e,a)=>t(e,!a))},a)}function V(e){return(t,a,n)=>e(t,n)}function Y(e){return u(e)?e:function(...t){var a=t.pop(),n=!0;t.push((...e)=>{n?Ee(()=>a(...e)):a(...e)}),e.apply(this,t),n=!1}}function q(e,t,a,n){var r=Array(t.length);e(t,(e,t,n)=>{a(e,(e,a)=>{r[t]=!!a,n(e)})},e=>{if(e)return n(e);for(var a=[],s=0;s<t.length;s++)r[s]&&a.push(t[s]);n(null,a)})}function D(e,t,a,n){var i=[];e(t,(e,t,n)=>{a(e,(a,r)=>a?n(a):void(r&&i.push({index:t,value:e}),n(a)))},e=>e?n(e):void n(null,i.sort((e,t)=>e.index-t.index).map(e=>e.value)))}function Q(e,t,a,n){var i=y(t)?q:D;return i(e,t,d(a),n)}function U(e,t,a){return lt(e,1/0,t,a)}function G(e,t,a){return lt(e,1,t,a)}function W(e,t,a){return ct(e,1/0,t,a)}function H(e,t,a){return ct(e,1,t,a)}function J(e,t=e=>e){var n=Object.create(null),r=Object.create(null),s=d(e),l=a((e,a)=>{var u=t(...e);u in n?Ee(()=>a(null,...n[u])):u in r?r[u].push(a):(r[u]=[a],s(...e,(e,...t)=>{e||(n[u]=t);var a=r[u];delete r[u];for(var s=0,c=a.length;s<c;s++)a[s](e,...t)}))});return l.memo=n,l.unmemoized=e,l}function K(e,t){return dt(Me,e,t)}function X(e,t,a){return dt(Oe(t),e,a)}function Z(e,t){var a=d(e);return w((e,t)=>{a(e[0],t)},t,1)}function $(e){return(e<<1)+1}function ee(e){return(e+1>>1)-1}function te(e,t){return e.priority===t.priority?e.pushCount<t.pushCount:e.priority<t.priority}function ae(e,t){var a=Z(e,t);return a._tasks=new ot,a.push=function(e,t=0,n=()=>{}){if("function"!=typeof n)throw new Error("task callback must be a function");if(a.started=!0,Array.isArray(e)||(e=[e]),0===e.length&&a.idle())return Ee(()=>a.drain());for(var r,s=0,u=e.length;s<u;s++)r={data:e[s],priority:t,callback:n},a._tasks.push(r);Ee(a.process)},delete a.unshift,a}function ne(e,t,a,n){var i=[...e].reverse();return Ye(i,t,a,n)}function ie(e){var t=d(e);return a(function(e,a){return e.push((e,...t)=>{let n={};if(e&&(n.error=e),0<t.length){var i=t;1>=t.length&&([i]=t),n.value=i}a(null,n)}),t.apply(this,e)})}function re(e){var t;return Array.isArray(e)?t=e.map(ie):(t={},Object.keys(e).forEach(a=>{t[a]=ie.call(this,e[a])})),t}function se(e,t,a,n){const i=d(a);return Q(e,t,(e,t)=>{i(e,(e,a)=>{t(e,!a)})},n)}function le(e){return function(){return e}}function ue(e,t,a){function n(){r((e,...t)=>{!1===e||(e&&s++<i.times&&("function"!=typeof i.errorFilter||i.errorFilter(e))?setTimeout(n,i.intervalFunc(s-1)):a(e,...t))})}var i={times:gt,intervalFunc:le(kt)};if(3>arguments.length&&"function"==typeof e?(a=t||_(),t=e):(ce(i,e),a=a||_()),"function"!=typeof t)throw new Error("Invalid arguments for async.retry");var r=d(t),s=1;return n(),a[Fe]}function ce(e,a){if("object"==typeof a)e.times=+a.times||gt,e.intervalFunc="function"==typeof a.interval?a.interval:le(+a.interval||kt),e.errorFilter=a.errorFilter;else if("number"==typeof a||"string"==typeof a)e.times=+a||gt;else throw new Error("Invalid arguments for async.retry")}function pe(e,t){t||(t=e,e=null);let n=e&&e.arity||t.length;u(t)&&(n+=1);var i=d(t);return a((t,a)=>{function r(e){i(...t,e)}return(t.length<n-1||null==a)&&(t.push(a),a=_()),e?ue(e,r,a):ue(r,a),a[Fe]})}function de(e,t){return dt(je,e,t)}function oe(e,t,n){var i=d(e);return a((a,r)=>{var s,l=!1;a.push((...e)=>{l||(r(...e),clearTimeout(s))}),s=setTimeout(function(){var t=e.name||"anonymous",a=new Error("Callback function \""+t+"\" timed out.");a.code="ETIMEDOUT",n&&(a.info=n),l=!0,r(a)},t),i(...a)})}function he(e){for(var t=Array(e);e--;)t[e]=e;return t}function fe(e,t,a,n){var i=d(a);return qe(he(e),t,i,n)}function ye(e,t,a){return fe(e,1/0,t,a)}function me(e,t,a){return fe(e,1,t,a)}function ge(e,t,a,n){3>=arguments.length&&"function"==typeof t&&(n=a,a=t,t=Array.isArray(e)?[]:{}),n=m(n||_());var i=d(a);return Me(e,(e,a,n)=>{i(t,e,a,n)},e=>n(e,t)),n[Fe]}function ke(e){return(...t)=>(e.unmemoized||e)(...t)}function ve(e,t,a){const n=d(e);return bt(e=>n((t,a)=>e(t,!a)),t,a)}var Se,Le="function"==typeof setImmediate&&setImmediate,xe="object"==typeof process&&"function"==typeof process.nextTick;Se=Le?setImmediate:xe?process.nextTick:n;var Ee=i(Se);const be={};var Oe=e=>(t,a,n)=>{function i(e,t){if(!u)if(d-=1,e)l=!0,n(e);else if(!1===e)l=!0,u=!0;else{if(t===be||l&&0>=d)return l=!0,n(null);o||r()}}function r(){for(o=!0;d<e&&!l;){var t=s();if(null===t)return l=!0,void(0>=d&&n(null));d+=1,a(t.value,t.key,x(i))}o=!1}if(n=m(n),0>=e)throw new RangeError("concurrency limit cannot be less than 1");if(!t)return n(null);if(c(t))return E(t,e,a,n);if(p(t))return E(t[Symbol.asyncIterator](),e,a,n);var s=L(t),l=!1,u=!1,d=0,o=!1;r()},_e=o(function(e,t,a,n){return Oe(t)(e,d(a),n)},4),Me=o(function(e,t,a){var n=y(e)?b:O;return n(e,d(t),a)},3),Ae=o(function(e,t,a){return f(Me,e,t,a)},3),Ie=h(Ae),je=o(function(e,t,a){return _e(e,1,t,a)},3),we=o(function(e,t,a){return f(je,e,t,a)},3),Be=h(we);const Fe=Symbol("promiseCallback");var Te=/^(?:async\s+)?(?:function)?\s*\w*\s*\(\s*([^)]+)\s*\)(?:\s*{)/,Ce=/^(?:async\s+)?\(?\s*([^)=]+)\s*\)?(?:\s*=>)/,Pe=/,/,Re=/(=.+)?(\s*)$/,ze=/((\/\/.*$)|(\/\*[\s\S]*?\*\/))/mg;class Ne{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):j(this,e)}push(e){this.tail?this.insertAfter(this.tail,e):j(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:a}=t;e(t)&&this.removeLink(t),t=a}return this}}var Ve,Ye=o(function(e,t,a,n){n=m(n);var r=d(a);return je(e,(e,a,n)=>{r(t,e,(e,a)=>{t=a,n(e)})},e=>n(e,t))},4),qe=o(function(e,t,a,n){return f(Oe(t),e,a,n)},4),De=o(function(e,t,a,n){var i=d(a);return qe(e,t,(e,t)=>{i(e,(e,...a)=>e?t(e):t(e,a))},(e,t)=>{for(var a=[],r=0;r<t.length;r++)t[r]&&(a=a.concat(...t[r]));return n(e,a)})},4),Qe=o(function(e,t,a){return De(e,1/0,t,a)},3),Ue=o(function(e,t,a){return De(e,1,t,a)},3),Ge=o(function(e,t,a){return R(e=>e,(e,t)=>t)(Me,e,t,a)},3),We=o(function(e,t,a,n){return R(e=>e,(e,t)=>t)(Oe(t),e,a,n)},4),He=o(function(e,t,a){return R(e=>e,(e,t)=>t)(Oe(1),e,t,a)},3),Je=z("dir"),Ke=o(function(e,t,a){function n(e,...t){return e?a(e):void(!1===e||(r=t,l(...t,i)))}function i(e,t){return e?a(e):!1===e?void 0:t?void s(n):a(null,...r)}a=x(a);var r,s=d(e),l=d(t);return i(null,!0)},3),Xe=o(function(e,t,a){return Me(e,V(d(t)),a)},3),Ze=o(function(e,t,a,n){return Oe(t)(e,V(d(a)),n)},4),$e=o(function(e,t,a){return Ze(e,1,t,a)},3),et=o(function(e,t,a){return R(e=>!e,e=>!e)(Me,e,t,a)},3),tt=o(function(e,t,a,n){return R(e=>!e,e=>!e)(Oe(t),e,a,n)},4),at=o(function(e,t,a){return R(e=>!e,e=>!e)(je,e,t,a)},3),nt=o(function(e,t,a){return Q(Me,e,t,a)},3),it=o(function(e,t,a,n){return Q(Oe(t),e,a,n)},4),rt=o(function(e,t,a){return Q(je,e,t,a)},3),st=o(function(e,t){function a(e){return e?n(e):void(!1===e||i(a))}var n=x(t),i=d(Y(e));return a()},2),lt=o(function(e,t,a,n){var i=d(a);return qe(e,t,(e,t)=>{i(e,(a,n)=>a?t(a):t(a,{key:n,val:e}))},(e,t)=>{for(var a={},{hasOwnProperty:r}=Object.prototype,s=0;s<t.length;s++)if(t[s]){var{key:l}=t[s],{val:u}=t[s];r.call(a,l)?a[l].push(u):a[l]=[u]}return n(e,a)})},4),ut=z("log"),ct=o(function(e,t,a,n){n=m(n);var i={},r=d(a);return Oe(t)(e,(e,t,a)=>{r(e,t,(e,n)=>e?a(e):void(i[t]=n,a(e)))},e=>n(e,i))},4);Ve=xe?process.nextTick:Le?setImmediate:n;var pt=i(Ve),dt=o((e,t,a)=>{var n=y(t)?[]:{};e(t,(e,t,a)=>{d(e)((e,...i)=>{2>i.length&&([i]=i),n[t]=i,a(e)})},e=>a(e,n))},3);class ot{constructor(){this.heap=[],this.pushCount=Number.MIN_SAFE_INTEGER}get length(){return this.heap.length}empty(){return this.heap=[],this}percUp(e){for(let a;0<e&&te(this.heap[e],this.heap[a=ee(e)]);){let n=this.heap[e];this.heap[e]=this.heap[a],this.heap[a]=n,e=a}}percDown(e){for(let a,n;(a=$(e))<this.heap.length&&(a+1<this.heap.length&&te(this.heap[a+1],this.heap[a])&&++a,!te(this.heap[e],this.heap[a]));)n=this.heap[e],this.heap[e]=this.heap[a],this.heap[a]=n,e=a}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 a=0;a<this.heap.length;a++)e(this.heap[a])||(this.heap[t]=this.heap[a],t++);this.heap.splice(t);for(let t=ee(this.heap.length-1);0<=t;t--)this.percDown(t);return this}}var ht=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 a=0,n=e.length;a<n;a++)d(e[a])(t)},2),ft=o(function(e,t,a){return se(Me,e,t,a)},3),yt=o(function(e,t,a,n){return se(Oe(t),e,a,n)},4),mt=o(function(e,t,a){return se(je,e,t,a)},3);const gt=5,kt=0;var vt=o(function(e,t,a){return R(Boolean,e=>e)(Me,e,t,a)},3),St=o(function(e,t,a,n){return R(Boolean,e=>e)(Oe(t),e,a,n)},4),Lt=o(function(e,t,a){return R(Boolean,e=>e)(je,e,t,a)},3),xt=o(function(e,t,a){function n(e,t){var n=e.criteria,a=t.criteria;return n<a?-1:n>a?1:0}var i=d(t);return Ae(e,(e,t)=>{i(e,(a,n)=>a?t(a):void t(a,{value:e,criteria:n}))},(e,t)=>e?a(e):void a(null,t.sort(n).map(e=>e.value)))},3),Et=o(function(e,t){var a,n=null;return $e(e,(e,t)=>{d(e)((e,...i)=>!1===e?t(e):void(2>i.length?[a]=i:a=i,n=e,t(e?null:{})))},()=>t(n,a))}),bt=o(function(e,t,a){function n(e,...t){if(e)return a(e);l=t;!1===e||s(i)}function i(e,t){return e?a(e):!1===e?void 0:t?void r(n):a(null,...l)}a=x(a);var r=d(t),s=d(e),l=[];return s(i)},3),Ot=o(function(e,t){function a(t){var a=d(e[i++]);a(...t,x(n))}function n(n,...r){return!1===n?void 0:n||i===e.length?t(n,...r):void a(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;a([])});e.default={apply:t,applyEach:Ie,applyEachSeries:Be,asyncify:r,auto:M,autoInject:I,cargo:B,cargoQueue:F,compose:C,concat:Qe,concatLimit:De,concatSeries:Ue,constant:P,detect:Ge,detectLimit:We,detectSeries:He,dir:Je,doUntil:N,doWhilst:Ke,each:Xe,eachLimit:Ze,eachOf:Me,eachOfLimit:_e,eachOfSeries:je,eachSeries:$e,ensureAsync:Y,every:et,everyLimit:tt,everySeries:at,filter:nt,filterLimit:it,filterSeries:rt,forever:st,groupBy:U,groupByLimit:lt,groupBySeries:G,log:ut,map:Ae,mapLimit:qe,mapSeries:we,mapValues:W,mapValuesLimit:ct,mapValuesSeries:H,memoize:J,nextTick:pt,parallel:K,parallelLimit:X,priorityQueue:ae,queue:Z,race:ht,reduce:Ye,reduceRight:ne,reflect:ie,reflectAll:re,reject:ft,rejectLimit:yt,rejectSeries:mt,retry:ue,retryable:pe,seq:T,series:de,setImmediate:Ee,some:vt,someLimit:St,someSeries:Lt,sortBy:xt,timeout:oe,times:ye,timesLimit:fe,timesSeries:me,transform:ge,tryEach:Et,unmemoize:ke,until:ve,waterfall:Ot,whilst:bt,all:et,allLimit:tt,allSeries:at,any:vt,anyLimit:St,anySeries:Lt,find:Ge,findLimit:We,findSeries:He,flatMap:Qe,flatMapLimit:De,flatMapSeries:Ue,forEach:Xe,forEachSeries:$e,forEachLimit:Ze,forEachOf:Me,forEachOfSeries:je,forEachOfLimit:_e,inject:Ye,foldl:Ye,foldr:ne,select:nt,selectLimit:it,selectSeries:rt,wrapSync:r,during:bt,doDuring:Ke},e.apply=t,e.applyEach=Ie,e.applyEachSeries=Be,e.asyncify=r,e.auto=M,e.autoInject=I,e.cargo=B,e.cargoQueue=F,e.compose=C,e.concat=Qe,e.concatLimit=De,e.concatSeries=Ue,e.constant=P,e.detect=Ge,e.detectLimit=We,e.detectSeries=He,e.dir=Je,e.doUntil=N,e.doWhilst=Ke,e.each=Xe,e.eachLimit=Ze,e.eachOf=Me,e.eachOfLimit=_e,e.eachOfSeries=je,e.eachSeries=$e,e.ensureAsync=Y,e.every=et,e.everyLimit=tt,e.everySeries=at,e.filter=nt,e.filterLimit=it,e.filterSeries=rt,e.forever=st,e.groupBy=U,e.groupByLimit=lt,e.groupBySeries=G,e.log=ut,e.map=Ae,e.mapLimit=qe,e.mapSeries=we,e.mapValues=W,e.mapValuesLimit=ct,e.mapValuesSeries=H,e.memoize=J,e.nextTick=pt,e.parallel=K,e.parallelLimit=X,e.priorityQueue=ae,e.queue=Z,e.race=ht,e.reduce=Ye,e.reduceRight=ne,e.reflect=ie,e.reflectAll=re,e.reject=ft,e.rejectLimit=yt,e.rejectSeries=mt,e.retry=ue,e.retryable=pe,e.seq=T,e.series=de,e.setImmediate=Ee,e.some=vt,e.someLimit=St,e.someSeries=Lt,e.sortBy=xt,e.timeout=oe,e.times=ye,e.timesLimit=fe,e.timesSeries=me,e.transform=ge,e.tryEach=Et,e.unmemoize=ke,e.until=ve,e.waterfall=Ot,e.whilst=bt,e.all=et,e.allLimit=tt,e.allSeries=at,e.any=vt,e.anyLimit=St,e.anySeries=Lt,e.find=Ge,e.findLimit=We,e.findSeries=He,e.flatMap=Qe,e.flatMapLimit=De,e.flatMapSeries=Ue,e.forEach=Xe,e.forEachSeries=$e,e.forEachLimit=Ze,e.forEachOf=Me,e.forEachOfSeries=je,e.forEachOfLimit=_e,e.inject=Ye,e.foldl=Ye,e.foldr=ne,e.select=nt,e.selectLimit=it,e.selectSeries=rt,e.wrapSync=r,e.during=bt,e.doDuring=Ke,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):t(e.async={})})(this,function(e){'use strict';function t(e,...t){return(...a)=>e(...t,...a)}function a(e){return function(...t){var a=t.pop();return e.call(this,t,a)}}function n(e){setTimeout(e,0)}function i(e){return(t,...a)=>e(()=>t(...a))}function r(e){return u(e)?function(...t){const a=t.pop(),n=e.apply(this,t);return s(n,a)}:a(function(t,a){var n;try{n=e.apply(this,t)}catch(t){return a(t)}return n&&"function"==typeof n.then?s(n,a):void a(null,n)})}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,a){try{e(t,a)}catch(e){be(t=>{throw t},e)}}function u(e){return"AsyncFunction"===e[Symbol.toStringTag]}function c(e){return"AsyncGenerator"===e[Symbol.toStringTag]}function p(e){return"function"==typeof e[Symbol.asyncIterator]}function d(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(...a){return"function"==typeof a[t-1]?e.apply(this,a):new Promise((n,i)=>{a[t-1]=(e,...t)=>e?i(e):void n(1<t.length?t:t[0]),e.apply(this,a)})}}function h(e){return function(t,...a){const n=o(function(n){var i=this;return e(t,(e,t)=>{d(e).apply(i,a.concat(t))},n)});return n}}function f(e,t,a,n){t=t||[];var i=[],r=0,s=d(a);return e(t,(e,t,a)=>{var n=r++;s(e,(e,t)=>{i[n]=t,a(e)})},e=>{n(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 a=e;e=null,a.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,a=e.length;return function(){return++t<a?{value:e[t],key:t}:null}}function v(e){var t=-1;return function(){var a=e.next();return a.done?null:(t++,{value:a.value,key:t})}}function S(e){var t=e?Object.keys(e):[],a=-1,n=t.length;return function(){var i=t[++a];return a<n?{value:e[i],key:i}:null}}function L(e){if(y(e))return k(e);var t=g(e);return t?v(t):S(e)}function x(e){return function(...t){if(null===e)throw new Error("Callback was already called.");var a=e;e=null,a.apply(this,t)}}function E(e,t,a,n){function i(){p>=t||c||l||(c=!0,e.next().then(({value:e,done:t})=>{if(!(u||l))return c=!1,t?(l=!0,void(0>=p&&n(null))):void(p++,a(e,d,r),d++,i())}).catch(s))}function r(e,t){return p-=1,u?void 0:e?s(e):!1===e?(l=!0,void(u=!0)):t===Oe||l&&0>=p?(l=!0,n(null)):void i()}function s(e){u||(c=!1,l=!0,n(e))}let l=!1,u=!1,c=!1,p=0,d=0;i()}function b(e,t,a){function n(e,t){!1===e&&(l=!0);!0===l||(e?a(e):(++r===s||t===Oe)&&a(null))}a=m(a);var i=0,r=0,{length:s}=e,l=!1;for(0===s&&a(null);i<s;i++)t(e[i],i,x(n))}function O(e,t,a){return Me(e,1/0,t,a)}function _(){function e(e,...n){return e?a(e):void t(1<n.length?n:n[0])}let t,a;return e[Te]=new Promise((e,n)=>{t=e,a=n}),e}function M(e,t,a){function n(e,t){g.push(()=>l(e,t))}function i(){if(!h){if(0===g.length&&0===o)return a(null,p);for(;g.length&&o<t;){var e=g.shift();e()}}}function r(e,t){var a=y[e];a||(a=y[e]=[]),a.push(t)}function s(e){var t=y[e]||[];t.forEach(e=>e()),i()}function l(e,t){if(!f){var n=x((t,...n)=>{if(o--,!1===t)return void(h=!0);if(2>n.length&&([n]=n),t){var i={};if(Object.keys(p).forEach(e=>{i[e]=p[e]}),i[e]=n,f=!0,y=Object.create(null),h)return;a(t,i)}else p[e]=n,s(e)});o++;var i=d(t[t.length-1]);1<t.length?i(p,n):i(n)}}function u(t){var a=[];return Object.keys(e).forEach(n=>{const i=e[n];Array.isArray(i)&&0<=i.indexOf(t)&&a.push(n)}),a}"number"!=typeof t&&(a=t,t=null),a=m(a||_());var c=Object.keys(e).length;if(!c)return a(null);t||(t=c);var p={},o=0,h=!1,f=!1,y=Object.create(null),g=[],k=[],v={};return Object.keys(e).forEach(t=>{var a=e[t];if(!Array.isArray(a))return n(t,[a]),void k.push(t);var i=a.slice(0,a.length-1),s=i.length;return 0===s?(n(t,a),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&&n(t,a)})}))}),function(){for(var e,t=0;k.length;)e=k.pop(),t++,u(e).forEach(e=>{0==--v[e]&&k.push(e)});if(t!==c)throw new Error("async.auto cannot execute tasks due to a recursive dependency")}(),i(),a[Te]}function A(e){const t=e.toString().replace(Ne,"");let a=t.match(Ce);if(a||(a=t.match(Pe)),!a)throw new Error("could not parse args in autoInject\nSource:\n"+t);let[,n]=a;return n.replace(/\s/g,"").split(Re).map(e=>e.replace(ze,"").trim())}function I(e,t){var a={};return Object.keys(e).forEach(t=>{function n(e,t){var a=i.map(t=>e[t]);a.push(t),d(r)(...a)}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(),a[t]=i.concat(0<i.length?n:r);else if(l)a[t]=r;else{if(i=A(r),0===r.length&&!s&&0===i.length)throw new Error("autoInject task functions require explicit parameters.");s||i.pop(),a[t]=i.concat(n)}}),M(a,t)}function j(e,t){e.length=1,e.head=e.tail=t}function w(e,t,a){function n(e,t){f[e].push(t)}function i(e,t){const a=(...n)=>{r(e,a),t(...n)};f[e].push(a)}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,a,n){function i(e,...t){return e?a?s(e):r():1>=t.length?r(t[0]):void r(t)}if(null!=n&&"function"!=typeof n)throw new Error("task callback must be a function");k.started=!0;var r,s,l={data:e,callback:a?i:n||i};if(t?k._tasks.unshift(l):k._tasks.push(l),y||(y=!0,be(()=>{y=!1,k.process()})),a||!n)return new Promise((e,t)=>{r=e,s=t})}function u(e){return function(t,...a){o-=1;for(var n=0,r=e.length;n<r;n++){var l=e[n],u=h.indexOf(l);0===u?h.shift():0<u&&h.splice(u,1),l.callback(t,...a),null!=t&&s("error",t,l.data)}o<=k.concurrency-k.buffer&&s("unsaturated"),k.idle()&&s("drain"),k.process()}}function c(e){return!!(0===e.length&&k.idle())&&(be(()=>s("drain")),!0)}if(null==t)t=1;else if(0===t)throw new RangeError("Concurrency must not be zero");var p=d(e),o=0,h=[];const f={error:[],drain:[],saturated:[],unsaturated:[],empty:[]};var y=!1;const m=e=>t=>t?void(r(e),n(e,t)):new Promise((t,a)=>{i(e,(e,n)=>e?a(e):void t(n))});var g=!1,k={_tasks:new Ve,*[Symbol.iterator](){yield*k._tasks[Symbol.iterator]()},concurrency:t,payload:a,buffer:t/4,started:!1,paused:!1,push(e,t){return Array.isArray(e)?c(e)?void 0:e.map(e=>l(e,!1,!1,t)):l(e,!1,!1,t)},pushAsync(e,t){return Array.isArray(e)?c(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)?c(e)?void 0:e.map(e=>l(e,!0,!1,t)):l(e,!0,!1,t)},unshiftAsync(e,t){return Array.isArray(e)?c(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=[],a=[],n=k._tasks.length;k.payload&&(n=e(n,k.payload));for(var r,c=0;c<n;c++)r=k._tasks.shift(),t.push(r),h.push(r),a.push(r.data);o+=1,0===k._tasks.length&&s("empty"),o===k.concurrency&&s("saturated");var d=x(u(t));p(a,d)}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,be(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 B(e,t){return w(e,1,t)}function F(e,t,a){return w(e,t,a)}function T(...e){var t=e.map(d);return function(...e){var a=this,n=e[e.length-1];return"function"==typeof n?e.pop():n=_(),qe(t,e,(e,t,n)=>{t.apply(a,e.concat((e,...t)=>{n(e,t)}))},(e,t)=>n(e,...t)),n[Te]}}function C(...e){return T(...e.reverse())}function P(...e){return function(...t){var a=t.pop();return a(null,...e)}}function R(e,t){return(a,n,i,r)=>{var s,l=!1;const u=d(i);a(n,(a,n,i)=>{u(a,(n,r)=>n||!1===n?i(n):e(r)&&!s?(l=!0,s=t(!0,a),i(null,Oe)):void i())},e=>e?r(e):void r(null,l?s:t(!1)))}}function z(e){return(t,...a)=>d(t)(...a,(t,...a)=>{"object"==typeof console&&(t?console.error&&console.error(t):console[e]&&a.forEach(t=>console[e](t)))})}function N(e,t,a){const n=d(t);return Xe(e,(...e)=>{const t=e.pop();n(...e,(e,a)=>t(e,!a))},a)}function V(e){return(t,a,n)=>e(t,n)}function Y(e){return u(e)?e:function(...t){var a=t.pop(),n=!0;t.push((...e)=>{n?be(()=>a(...e)):a(...e)}),e.apply(this,t),n=!1}}function q(e,t,a,n){var r=Array(t.length);e(t,(e,t,n)=>{a(e,(e,a)=>{r[t]=!!a,n(e)})},e=>{if(e)return n(e);for(var a=[],s=0;s<t.length;s++)r[s]&&a.push(t[s]);n(null,a)})}function D(e,t,a,n){var i=[];e(t,(e,t,n)=>{a(e,(a,r)=>a?n(a):void(r&&i.push({index:t,value:e}),n(a)))},e=>e?n(e):void n(null,i.sort((e,t)=>e.index-t.index).map(e=>e.value)))}function Q(e,t,a,n){var i=y(t)?q:D;return i(e,t,d(a),n)}function U(e,t,a){return ut(e,1/0,t,a)}function G(e,t,a){return ut(e,1,t,a)}function W(e,t,a){return pt(e,1/0,t,a)}function H(e,t,a){return pt(e,1,t,a)}function J(e,t=e=>e){var n=Object.create(null),r=Object.create(null),s=d(e),l=a((e,a)=>{var u=t(...e);u in n?be(()=>a(null,...n[u])):u in r?r[u].push(a):(r[u]=[a],s(...e,(e,...t)=>{e||(n[u]=t);var a=r[u];delete r[u];for(var s=0,c=a.length;s<c;s++)a[s](e,...t)}))});return l.memo=n,l.unmemoized=e,l}function K(e,t){return ot(Ae,e,t)}function X(e,t,a){return ot(_e(t),e,a)}function Z(e,t){var a=d(e);return w((e,t)=>{a(e[0],t)},t,1)}function $(e){return(e<<1)+1}function ee(e){return(e+1>>1)-1}function te(e,t){return e.priority===t.priority?e.pushCount<t.pushCount:e.priority<t.priority}function ae(e,t){var a=Z(e,t),n=!1;return a._tasks=new ht,a.push=function(e,t=0,r=()=>{}){if("function"!=typeof r)throw new Error("task callback must be a function");if(a.started=!0,Array.isArray(e)||(e=[e]),0===e.length&&a.idle())return be(()=>a.drain());for(var s,u=0,c=e.length;u<c;u++)s={data:e[u],priority:t,callback:r},a._tasks.push(s);n||(n=!0,be(()=>{n=!1,a.process()}))},delete a.unshift,a}function ne(e,t,a,n){var i=[...e].reverse();return qe(i,t,a,n)}function ie(e){var t=d(e);return a(function(e,a){return e.push((e,...t)=>{let n={};if(e&&(n.error=e),0<t.length){var i=t;1>=t.length&&([i]=t),n.value=i}a(null,n)}),t.apply(this,e)})}function re(e){var t;return Array.isArray(e)?t=e.map(ie):(t={},Object.keys(e).forEach(a=>{t[a]=ie.call(this,e[a])})),t}function se(e,t,a,n){const i=d(a);return Q(e,t,(e,t)=>{i(e,(e,a)=>{t(e,!a)})},n)}function le(e){return function(){return e}}function ue(e,t,a){function n(){r((e,...t)=>{!1===e||(e&&s++<i.times&&("function"!=typeof i.errorFilter||i.errorFilter(e))?setTimeout(n,i.intervalFunc(s-1)):a(e,...t))})}var i={times:kt,intervalFunc:le(vt)};if(3>arguments.length&&"function"==typeof e?(a=t||_(),t=e):(ce(i,e),a=a||_()),"function"!=typeof t)throw new Error("Invalid arguments for async.retry");var r=d(t),s=1;return n(),a[Te]}function ce(e,a){if("object"==typeof a)e.times=+a.times||kt,e.intervalFunc="function"==typeof a.interval?a.interval:le(+a.interval||vt),e.errorFilter=a.errorFilter;else if("number"==typeof a||"string"==typeof a)e.times=+a||kt;else throw new Error("Invalid arguments for async.retry")}function pe(e,t){t||(t=e,e=null);let n=e&&e.arity||t.length;u(t)&&(n+=1);var i=d(t);return a((t,a)=>{function r(e){i(...t,e)}return(t.length<n-1||null==a)&&(t.push(a),a=_()),e?ue(e,r,a):ue(r,a),a[Te]})}function de(e,t){return ot(we,e,t)}function oe(e,t,n){var i=d(e);return a((a,r)=>{var s,l=!1;a.push((...e)=>{l||(r(...e),clearTimeout(s))}),s=setTimeout(function(){var t=e.name||"anonymous",a=new Error("Callback function \""+t+"\" timed out.");a.code="ETIMEDOUT",n&&(a.info=n),l=!0,r(a)},t),i(...a)})}function he(e){for(var t=Array(e);e--;)t[e]=e;return t}function fe(e,t,a,n){var i=d(a);return De(he(e),t,i,n)}function ye(e,t,a){return fe(e,1/0,t,a)}function me(e,t,a){return fe(e,1,t,a)}function ge(e,t,a,n){3>=arguments.length&&"function"==typeof t&&(n=a,a=t,t=Array.isArray(e)?[]:{}),n=m(n||_());var i=d(a);return Ae(e,(e,a,n)=>{i(t,e,a,n)},e=>n(e,t)),n[Te]}function ke(e){return(...t)=>(e.unmemoized||e)(...t)}function ve(e,t,a){const n=d(e);return Ot(e=>n((t,a)=>e(t,!a)),t,a)}var Se,Le="function"==typeof queueMicrotask&&queueMicrotask,xe="function"==typeof setImmediate&&setImmediate,Ee="object"==typeof process&&"function"==typeof process.nextTick;Se=Le?queueMicrotask:xe?setImmediate:Ee?process.nextTick:n;var be=i(Se);const Oe={};var _e=e=>(t,a,n)=>{function i(e,t){if(!u)if(d-=1,e)l=!0,n(e);else if(!1===e)l=!0,u=!0;else{if(t===Oe||l&&0>=d)return l=!0,n(null);o||r()}}function r(){for(o=!0;d<e&&!l;){var t=s();if(null===t)return l=!0,void(0>=d&&n(null));d+=1,a(t.value,t.key,x(i))}o=!1}if(n=m(n),0>=e)throw new RangeError("concurrency limit cannot be less than 1");if(!t)return n(null);if(c(t))return E(t,e,a,n);if(p(t))return E(t[Symbol.asyncIterator](),e,a,n);var s=L(t),l=!1,u=!1,d=0,o=!1;r()},Me=o(function(e,t,a,n){return _e(t)(e,d(a),n)},4),Ae=o(function(e,t,a){var n=y(e)?b:O;return n(e,d(t),a)},3),Ie=o(function(e,t,a){return f(Ae,e,t,a)},3),je=h(Ie),we=o(function(e,t,a){return Me(e,1,t,a)},3),Be=o(function(e,t,a){return f(we,e,t,a)},3),Fe=h(Be);const Te=Symbol("promiseCallback");var Ce=/^(?:async\s+)?(?:function)?\s*\w*\s*\(\s*([^)]+)\s*\)(?:\s*{)/,Pe=/^(?:async\s+)?\(?\s*([^)=]+)\s*\)?(?:\s*=>)/,Re=/,/,ze=/(=.+)?(\s*)$/,Ne=/((\/\/.*$)|(\/\*[\s\S]*?\*\/))/mg;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):j(this,e)}push(e){this.tail?this.insertAfter(this.tail,e):j(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:a}=t;e(t)&&this.removeLink(t),t=a}return this}}var Ye,qe=o(function(e,t,a,n){n=m(n);var r=d(a);return we(e,(e,a,n)=>{r(t,e,(e,a)=>{t=a,n(e)})},e=>n(e,t))},4),De=o(function(e,t,a,n){return f(_e(t),e,a,n)},4),Qe=o(function(e,t,a,n){var i=d(a);return De(e,t,(e,t)=>{i(e,(e,...a)=>e?t(e):t(e,a))},(e,t)=>{for(var a=[],r=0;r<t.length;r++)t[r]&&(a=a.concat(...t[r]));return n(e,a)})},4),Ue=o(function(e,t,a){return Qe(e,1/0,t,a)},3),Ge=o(function(e,t,a){return Qe(e,1,t,a)},3),We=o(function(e,t,a){return R(e=>e,(e,t)=>t)(Ae,e,t,a)},3),He=o(function(e,t,a,n){return R(e=>e,(e,t)=>t)(_e(t),e,a,n)},4),Je=o(function(e,t,a){return R(e=>e,(e,t)=>t)(_e(1),e,t,a)},3),Ke=z("dir"),Xe=o(function(e,t,a){function n(e,...t){return e?a(e):void(!1===e||(r=t,l(...t,i)))}function i(e,t){return e?a(e):!1===e?void 0:t?void s(n):a(null,...r)}a=x(a);var r,s=d(e),l=d(t);return i(null,!0)},3),Ze=o(function(e,t,a){return Ae(e,V(d(t)),a)},3),$e=o(function(e,t,a,n){return _e(t)(e,V(d(a)),n)},4),et=o(function(e,t,a){return $e(e,1,t,a)},3),tt=o(function(e,t,a){return R(e=>!e,e=>!e)(Ae,e,t,a)},3),at=o(function(e,t,a,n){return R(e=>!e,e=>!e)(_e(t),e,a,n)},4),nt=o(function(e,t,a){return R(e=>!e,e=>!e)(we,e,t,a)},3),it=o(function(e,t,a){return Q(Ae,e,t,a)},3),rt=o(function(e,t,a,n){return Q(_e(t),e,a,n)},4),st=o(function(e,t,a){return Q(we,e,t,a)},3),lt=o(function(e,t){function a(e){return e?n(e):void(!1===e||i(a))}var n=x(t),i=d(Y(e));return a()},2),ut=o(function(e,t,a,n){var i=d(a);return De(e,t,(e,t)=>{i(e,(a,n)=>a?t(a):t(a,{key:n,val:e}))},(e,t)=>{for(var a={},{hasOwnProperty:r}=Object.prototype,s=0;s<t.length;s++)if(t[s]){var{key:l}=t[s],{val:u}=t[s];r.call(a,l)?a[l].push(u):a[l]=[u]}return n(e,a)})},4),ct=z("log"),pt=o(function(e,t,a,n){n=m(n);var i={},r=d(a);return _e(t)(e,(e,t,a)=>{r(e,t,(e,n)=>e?a(e):void(i[t]=n,a(e)))},e=>n(e,i))},4);Ye=Ee?process.nextTick:xe?setImmediate:n;var dt=i(Ye),ot=o((e,t,a)=>{var n=y(t)?[]:{};e(t,(e,t,a)=>{d(e)((e,...i)=>{2>i.length&&([i]=i),n[t]=i,a(e)})},e=>a(e,n))},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 a;0<e&&te(this.heap[e],this.heap[a=ee(e)]);){let n=this.heap[e];this.heap[e]=this.heap[a],this.heap[a]=n,e=a}}percDown(e){for(let a,n;(a=$(e))<this.heap.length&&(a+1<this.heap.length&&te(this.heap[a+1],this.heap[a])&&++a,!te(this.heap[e],this.heap[a]));)n=this.heap[e],this.heap[e]=this.heap[a],this.heap[a]=n,e=a}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 a=0;a<this.heap.length;a++)e(this.heap[a])||(this.heap[t]=this.heap[a],t++);this.heap.splice(t);for(let t=ee(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 a=0,n=e.length;a<n;a++)d(e[a])(t)},2),yt=o(function(e,t,a){return se(Ae,e,t,a)},3),mt=o(function(e,t,a,n){return se(_e(t),e,a,n)},4),gt=o(function(e,t,a){return se(we,e,t,a)},3);const kt=5,vt=0;var St=o(function(e,t,a){return R(Boolean,e=>e)(Ae,e,t,a)},3),Lt=o(function(e,t,a,n){return R(Boolean,e=>e)(_e(t),e,a,n)},4),xt=o(function(e,t,a){return R(Boolean,e=>e)(we,e,t,a)},3),Et=o(function(e,t,a){function n(e,t){var n=e.criteria,a=t.criteria;return n<a?-1:n>a?1:0}var i=d(t);return Ie(e,(e,t)=>{i(e,(a,n)=>a?t(a):void t(a,{value:e,criteria:n}))},(e,t)=>e?a(e):void a(null,t.sort(n).map(e=>e.value)))},3),bt=o(function(e,t){var a,n=null;return et(e,(e,t)=>{d(e)((e,...i)=>!1===e?t(e):void(2>i.length?[a]=i:a=i,n=e,t(e?null:{})))},()=>t(n,a))}),Ot=o(function(e,t,a){function n(e,...t){if(e)return a(e);l=t;!1===e||s(i)}function i(e,t){return e?a(e):!1===e?void 0:t?void r(n):a(null,...l)}a=x(a);var r=d(t),s=d(e),l=[];return s(i)},3),_t=o(function(e,t){function a(t){var a=d(e[i++]);a(...t,x(n))}function n(n,...r){return!1===n?void 0:n||i===e.length?t(n,...r):void a(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;a([])});e.default={apply:t,applyEach:je,applyEachSeries:Fe,asyncify:r,auto:M,autoInject:I,cargo:B,cargoQueue:F,compose:C,concat:Ue,concatLimit:Qe,concatSeries:Ge,constant:P,detect:We,detectLimit:He,detectSeries:Je,dir:Ke,doUntil:N,doWhilst:Xe,each:Ze,eachLimit:$e,eachOf:Ae,eachOfLimit:Me,eachOfSeries:we,eachSeries:et,ensureAsync:Y,every:tt,everyLimit:at,everySeries:nt,filter:it,filterLimit:rt,filterSeries:st,forever:lt,groupBy:U,groupByLimit:ut,groupBySeries:G,log:ct,map:Ie,mapLimit:De,mapSeries:Be,mapValues:W,mapValuesLimit:pt,mapValuesSeries:H,memoize:J,nextTick:dt,parallel:K,parallelLimit:X,priorityQueue:ae,queue:Z,race:ft,reduce:qe,reduceRight:ne,reflect:ie,reflectAll:re,reject:yt,rejectLimit:mt,rejectSeries:gt,retry:ue,retryable:pe,seq:T,series:de,setImmediate:be,some:St,someLimit:Lt,someSeries:xt,sortBy:Et,timeout:oe,times:ye,timesLimit:fe,timesSeries:me,transform:ge,tryEach:bt,unmemoize:ke,until:ve,waterfall:_t,whilst:Ot,all:tt,allLimit:at,allSeries:nt,any:St,anyLimit:Lt,anySeries:xt,find:We,findLimit:He,findSeries:Je,flatMap:Ue,flatMapLimit:Qe,flatMapSeries:Ge,forEach:Ze,forEachSeries:et,forEachLimit:$e,forEachOf:Ae,forEachOfSeries:we,forEachOfLimit:Me,inject:qe,foldl:qe,foldr:ne,select:it,selectLimit:rt,selectSeries:st,wrapSync:r,during:Ot,doDuring:Xe},e.apply=t,e.applyEach=je,e.applyEachSeries=Fe,e.asyncify=r,e.auto=M,e.autoInject=I,e.cargo=B,e.cargoQueue=F,e.compose=C,e.concat=Ue,e.concatLimit=Qe,e.concatSeries=Ge,e.constant=P,e.detect=We,e.detectLimit=He,e.detectSeries=Je,e.dir=Ke,e.doUntil=N,e.doWhilst=Xe,e.each=Ze,e.eachLimit=$e,e.eachOf=Ae,e.eachOfLimit=Me,e.eachOfSeries=we,e.eachSeries=et,e.ensureAsync=Y,e.every=tt,e.everyLimit=at,e.everySeries=nt,e.filter=it,e.filterLimit=rt,e.filterSeries=st,e.forever=lt,e.groupBy=U,e.groupByLimit=ut,e.groupBySeries=G,e.log=ct,e.map=Ie,e.mapLimit=De,e.mapSeries=Be,e.mapValues=W,e.mapValuesLimit=pt,e.mapValuesSeries=H,e.memoize=J,e.nextTick=dt,e.parallel=K,e.parallelLimit=X,e.priorityQueue=ae,e.queue=Z,e.race=ft,e.reduce=qe,e.reduceRight=ne,e.reflect=ie,e.reflectAll=re,e.reject=yt,e.rejectLimit=mt,e.rejectSeries=gt,e.retry=ue,e.retryable=pe,e.seq=T,e.series=de,e.setImmediate=be,e.some=St,e.someLimit=Lt,e.someSeries=xt,e.sortBy=Et,e.timeout=oe,e.times=ye,e.timesLimit=fe,e.timesSeries=me,e.transform=ge,e.tryEach=bt,e.unmemoize=ke,e.until=ve,e.waterfall=_t,e.whilst=Ot,e.all=tt,e.allLimit=at,e.allSeries=nt,e.any=St,e.anyLimit=Lt,e.anySeries=xt,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=Ae,e.forEachOfSeries=we,e.forEachOfLimit=Me,e.inject=qe,e.foldl=qe,e.foldr=ne,e.select=it,e.selectLimit=rt,e.selectSeries=st,e.wrapSync=r,e.during=Ot,e.doDuring=Xe,Object.defineProperty(e,"__esModule",{value:!0})}); |
89
each.js
@@ -51,33 +51,74 @@ 'use strict'; | ||
| * | ||
| * // assuming openFiles is an array of file names and saveFile is a function | ||
| * // to save the modified contents of that file: | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * // dir4 does not exist | ||
| * | ||
| * async.each(openFiles, saveFile, function(err){ | ||
| * // if any of the saves produced an error, err would equal that error | ||
| * const fileList = [ 'dir1/file2.txt', 'dir2/file3.txt', 'dir/file5.txt']; | ||
| * const withMissingFileList = ['dir1/file1.txt', 'dir4/file2.txt']; | ||
| * | ||
| * // asynchronous function that deletes a file | ||
| * const deleteFile = function(file, callback) { | ||
| * fs.unlink(file, callback); | ||
| * }; | ||
| * | ||
| * // Using callbacks | ||
| * async.each(fileList, deleteFile, function(err) { | ||
| * if( err ) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log('All files have been deleted successfully'); | ||
| * } | ||
| * }); | ||
| * | ||
| * // assuming openFiles is an array of file names | ||
| * async.each(openFiles, function(file, callback) { | ||
| * // Error Handling | ||
| * async.each(withMissingFileList, deleteFile, function(err){ | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4/file2.txt does not exist | ||
| * // dir1/file1.txt could have been deleted | ||
| * }); | ||
| * | ||
| * // Perform operation on file here. | ||
| * console.log('Processing file ' + file); | ||
| * // Using Promises | ||
| * async.each(fileList, deleteFile) | ||
| * .then( () => { | ||
| * console.log('All files have been deleted successfully'); | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * if( file.length > 32 ) { | ||
| * console.log('This file name is too long'); | ||
| * callback('File name too long'); | ||
| * } else { | ||
| * // Do work to process file here | ||
| * console.log('File processed'); | ||
| * callback(); | ||
| * // Error Handling | ||
| * async.each(fileList, deleteFile) | ||
| * .then( () => { | ||
| * console.log('All files have been deleted successfully'); | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4/file2.txt does not exist | ||
| * // dir1/file1.txt could have been deleted | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * await async.each(files, deleteFile); | ||
| * } | ||
| * }, function(err) { | ||
| * // if any of the file processing produced an error, err would equal that error | ||
| * if( err ) { | ||
| * // One of the iterations produced an error. | ||
| * // All processing will now stop. | ||
| * console.log('A file failed to process'); | ||
| * } else { | ||
| * console.log('All files have been processed successfully'); | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * }); | ||
| * } | ||
| * | ||
| * // Error Handling | ||
| * async () => { | ||
| * try { | ||
| * await async.each(withMissingFileList, deleteFile); | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4/file2.txt does not exist | ||
| * // dir1/file1.txt could have been deleted | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -84,0 +125,0 @@ function eachLimit(coll, iteratee, callback) { |
@@ -91,8 +91,15 @@ 'use strict'; | ||
| * | ||
| * var obj = {dev: "/dev.json", test: "/test.json", prod: "/prod.json"}; | ||
| * var configs = {}; | ||
| * // dev.json is a file containing a valid json object config for dev environment | ||
| * // dev.json is a file containing a valid json object config for test environment | ||
| * // prod.json is a file containing a valid json object config for prod environment | ||
| * // invalid.json is a file with a malformed json object | ||
| * | ||
| * async.forEachOf(obj, function (value, key, callback) { | ||
| * fs.readFile(__dirname + value, "utf8", function (err, data) { | ||
| * if (err) return callback(err); | ||
| * let configs = {}; //global variable | ||
| * let validConfigFileMap = {dev: 'dev.json', test: 'test.json', prod: 'prod.json'}; | ||
| * let invalidConfigFileMap = {dev: 'dev.json', test: 'test.json', invalid: 'invalid.json'}; | ||
| * | ||
| * // asynchronous function that reads a json file and parses the contents as json object | ||
| * function parseFile(file, key, callback) { | ||
| * fs.readFile(file, "utf8", function(err, data) { | ||
| * if (err) return calback(err); | ||
| * try { | ||
@@ -105,7 +112,69 @@ * configs[key] = JSON.parse(data); | ||
| * }); | ||
| * }, function (err) { | ||
| * if (err) console.error(err.message); | ||
| * // configs is now a map of JSON data | ||
| * doSomethingWith(configs); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.forEachOf(validConfigFileMap, parseFile, function (err) { | ||
| * if (err) { | ||
| * console.error(err); | ||
| * } else { | ||
| * console.log(configs); | ||
| * // configs is now a map of JSON data, e.g. | ||
| * // { dev: //parsed dev.json, test: //parsed test.json, prod: //parsed prod.json} | ||
| * } | ||
| * }); | ||
| * | ||
| * //Error handing | ||
| * async.forEachOf(invalidConfigFileMap, parseFile, function (err) { | ||
| * if (err) { | ||
| * console.error(err); | ||
| * // JSON parse error exception | ||
| * } else { | ||
| * console.log(configs); | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.forEachOf(validConfigFileMap, parseFile) | ||
| * .then( () => { | ||
| * console.log(configs); | ||
| * // configs is now a map of JSON data, e.g. | ||
| * // { dev: //parsed dev.json, test: //parsed test.json, prod: //parsed prod.json} | ||
| * }).catch( err => { | ||
| * console.error(err); | ||
| * }); | ||
| * | ||
| * //Error handing | ||
| * async.forEachOf(invalidConfigFileMap, parseFile) | ||
| * .then( () => { | ||
| * console.log(configs); | ||
| * }).catch( err => { | ||
| * console.error(err); | ||
| * // JSON parse error exception | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.forEachOf(validConfigFileMap, parseFile); | ||
| * console.log(configs); | ||
| * // configs is now a map of JSON data, e.g. | ||
| * // { dev: //parsed dev.json, test: //parsed test.json, prod: //parsed prod.json} | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * //Error handing | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.forEachOf(invalidConfigFileMap, parseFile); | ||
| * console.log(configs); | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * // JSON parse error exception | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -112,0 +181,0 @@ function eachOf(coll, iteratee, callback) { |
77
every.js
@@ -42,9 +42,74 @@ 'use strict'; | ||
| * | ||
| * async.every(['file1','file2','file3'], function(filePath, callback) { | ||
| * fs.access(filePath, function(err) { | ||
| * callback(null, !err) | ||
| * }); | ||
| * }, function(err, result) { | ||
| * // if result is true then every file exists | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * // dir4 does not exist | ||
| * | ||
| * const fileList = ['dir1/file1.txt','dir2/file3.txt','dir3/file5.txt']; | ||
| * const withMissingFileList = ['file1.txt','file2.txt','file4.txt']; | ||
| * | ||
| * // asynchronous function that checks if a file exists | ||
| * function fileExists(file, callback) { | ||
| * fs.access(file, fs.constants.F_OK, (err) => { | ||
| * callback(null, !err); | ||
| * }); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.every(fileList, fileExists, function(err, result) { | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since every file exists | ||
| * }); | ||
| * | ||
| * async.every(withMissingFileList, fileExists, function(err, result) { | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since NOT every file exists | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.every(fileList, fileExists) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since every file exists | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * async.every(withMissingFileList, fileExists) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since NOT every file exists | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.every(fileList, fileExists); | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since every file exists | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.every(withMissingFileList, fileExists); | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since NOT every file exists | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -51,0 +116,0 @@ function every(coll, iteratee, callback) { |
@@ -41,9 +41,49 @@ 'use strict'; | ||
| * | ||
| * async.filter(['file1','file2','file3'], function(filePath, callback) { | ||
| * fs.access(filePath, function(err) { | ||
| * callback(null, !err) | ||
| * }); | ||
| * }, function(err, results) { | ||
| * // results now equals an array of the existing files | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * | ||
| * const files = ['dir1/file1.txt','dir2/file3.txt','dir3/file6.txt']; | ||
| * | ||
| * // asynchronous function that checks if a file exists | ||
| * function fileExists(file, callback) { | ||
| * fs.access(file, fs.constants.F_OK, (err) => { | ||
| * callback(null, !err); | ||
| * }); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.filter(files, fileExists, function(err, results) { | ||
| * if(err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(results); | ||
| * // [ 'dir1/file1.txt', 'dir2/file3.txt' ] | ||
| * // results is now an array of the existing files | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.filter(files, fileExists) | ||
| * .then(results => { | ||
| * console.log(results); | ||
| * // [ 'dir1/file1.txt', 'dir2/file3.txt' ] | ||
| * // results is now an array of the existing files | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.filter(files, fileExists); | ||
| * console.log(results); | ||
| * // [ 'dir1/file1.txt', 'dir2/file3.txt' ] | ||
| * // results is now an array of the existing files | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -50,0 +90,0 @@ function filter(coll, iteratee, callback) { |
45
find.js
@@ -49,9 +49,44 @@ 'use strict'; | ||
| * | ||
| * async.detect(['file1','file2','file3'], function(filePath, callback) { | ||
| * fs.access(filePath, function(err) { | ||
| * callback(null, !err) | ||
| * }); | ||
| * }, function(err, result) { | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * | ||
| * // asynchronous function that checks if a file exists | ||
| * function fileExists(file, callback) { | ||
| * fs.access(file, fs.constants.F_OK, (err) => { | ||
| * callback(null, !err); | ||
| * }); | ||
| * } | ||
| * | ||
| * async.detect(['file3.txt','file2.txt','dir1/file1.txt'], fileExists, | ||
| * function(err, result) { | ||
| * console.log(result); | ||
| * // dir1/file1.txt | ||
| * // result now equals the first file in the list that exists | ||
| * } | ||
| *); | ||
| * | ||
| * // Using Promises | ||
| * async.detect(['file3.txt','file2.txt','dir1/file1.txt'], fileExists) | ||
| * .then(result => { | ||
| * console.log(result); | ||
| * // dir1/file1.txt | ||
| * // result now equals the first file in the list that exists | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.detect(['file3.txt','file2.txt','dir1/file1.txt'], fileExists); | ||
| * console.log(result); | ||
| * // dir1/file1.txt | ||
| * // result now equals the file in the list that exists | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -58,0 +93,0 @@ function detect(coll, iteratee, callback) { |
@@ -39,5 +39,73 @@ 'use strict'; | ||
| * | ||
| * async.concat(['dir1','dir2','dir3'], fs.readdir, function(err, files) { | ||
| * // files is now a list of filenames that exist in the 3 directories | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * // dir4 does not exist | ||
| * | ||
| * let directoryList = ['dir1','dir2','dir3']; | ||
| * let withMissingDirectoryList = ['dir1','dir2','dir3', 'dir4']; | ||
| * | ||
| * // Using callbacks | ||
| * async.concat(directoryList, fs.readdir, function(err, results) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(results); | ||
| * // [ 'file1.txt', 'file2.txt', 'file3.txt', 'file4.txt', file5.txt ] | ||
| * } | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.concat(withMissingDirectoryList, fs.readdir, function(err, results) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4 does not exist | ||
| * } else { | ||
| * console.log(results); | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.concat(directoryList, fs.readdir) | ||
| * .then(results => { | ||
| * console.log(results); | ||
| * // [ 'file1.txt', 'file2.txt', 'file3.txt', 'file4.txt', file5.txt ] | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.concat(withMissingDirectoryList, fs.readdir) | ||
| * .then(results => { | ||
| * console.log(results); | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4 does not exist | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.concat(directoryList, fs.readdir); | ||
| * console.log(results); | ||
| * // [ 'file1.txt', 'file2.txt', 'file3.txt', 'file4.txt', file5.txt ] | ||
| * } catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * // Error Handling | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.concat(withMissingDirectoryList, fs.readdir); | ||
| * console.log(results); | ||
| * } catch (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4 does not exist | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -44,0 +112,0 @@ function concat(coll, iteratee, callback) { |
90
foldl.js
@@ -48,3 +48,3 @@ 'use strict'; | ||
| * The `iteratee` should complete with the next state of the reduction. | ||
| * If the iteratee complete with an error, the reduction is stopped and the | ||
| * If the iteratee completes with an error, the reduction is stopped and the | ||
| * main `callback` is immediately called with the error. | ||
@@ -58,10 +58,86 @@ * Invoked with (memo, item, callback). | ||
| * | ||
| * async.reduce([1,2,3], 0, function(memo, item, callback) { | ||
| * // pointless async: | ||
| * process.nextTick(function() { | ||
| * callback(null, memo + item) | ||
| * // file1.txt is a file that is 1000 bytes in size | ||
| * // file2.txt is a file that is 2000 bytes in size | ||
| * // file3.txt is a file that is 3000 bytes in size | ||
| * // file4.txt does not exist | ||
| * | ||
| * const fileList = ['file1.txt','file2.txt','file3.txt']; | ||
| * const withMissingFileList = ['file1.txt','file2.txt','file3.txt', 'file4.txt']; | ||
| * | ||
| * // asynchronous function that computes the file size in bytes | ||
| * // file size is added to the memoized value, then returned | ||
| * function getFileSizeInBytes(memo, file, callback) { | ||
| * fs.stat(file, function(err, stat) { | ||
| * if (err) { | ||
| * return callback(err); | ||
| * } | ||
| * callback(null, memo + stat.size); | ||
| * }); | ||
| * }, function(err, result) { | ||
| * // result is now equal to the last value of memo, which is 6 | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.reduce(fileList, 0, getFileSizeInBytes, function(err, result) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(result); | ||
| * // 6000 | ||
| * // which is the sum of the file sizes of the three files | ||
| * } | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.reduce(withMissingFileList, 0, getFileSizeInBytes, function(err, result) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } else { | ||
| * console.log(result); | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.reduce(fileList, 0, getFileSizeInBytes) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // 6000 | ||
| * // which is the sum of the file sizes of the three files | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.reduce(withMissingFileList, 0, getFileSizeInBytes) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.reduce(fileList, 0, getFileSizeInBytes); | ||
| * console.log(result); | ||
| * // 6000 | ||
| * // which is the sum of the file sizes of the three files | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * // Error Handling | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.reduce(withMissingFileList, 0, getFileSizeInBytes); | ||
| * console.log(result); | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -68,0 +144,0 @@ function reduce(coll, memo, iteratee, callback) { |
@@ -29,3 +29,3 @@ 'use strict'; | ||
| * The `iteratee` should complete with the next state of the reduction. | ||
| * If the iteratee complete with an error, the reduction is stopped and the | ||
| * If the iteratee completes with an error, the reduction is stopped and the | ||
| * main `callback` is immediately called with the error. | ||
@@ -32,0 +32,0 @@ * Invoked with (memo, item, callback). |
@@ -51,33 +51,74 @@ 'use strict'; | ||
| * | ||
| * // assuming openFiles is an array of file names and saveFile is a function | ||
| * // to save the modified contents of that file: | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * // dir4 does not exist | ||
| * | ||
| * async.each(openFiles, saveFile, function(err){ | ||
| * // if any of the saves produced an error, err would equal that error | ||
| * const fileList = [ 'dir1/file2.txt', 'dir2/file3.txt', 'dir/file5.txt']; | ||
| * const withMissingFileList = ['dir1/file1.txt', 'dir4/file2.txt']; | ||
| * | ||
| * // asynchronous function that deletes a file | ||
| * const deleteFile = function(file, callback) { | ||
| * fs.unlink(file, callback); | ||
| * }; | ||
| * | ||
| * // Using callbacks | ||
| * async.each(fileList, deleteFile, function(err) { | ||
| * if( err ) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log('All files have been deleted successfully'); | ||
| * } | ||
| * }); | ||
| * | ||
| * // assuming openFiles is an array of file names | ||
| * async.each(openFiles, function(file, callback) { | ||
| * // Error Handling | ||
| * async.each(withMissingFileList, deleteFile, function(err){ | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4/file2.txt does not exist | ||
| * // dir1/file1.txt could have been deleted | ||
| * }); | ||
| * | ||
| * // Perform operation on file here. | ||
| * console.log('Processing file ' + file); | ||
| * // Using Promises | ||
| * async.each(fileList, deleteFile) | ||
| * .then( () => { | ||
| * console.log('All files have been deleted successfully'); | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * if( file.length > 32 ) { | ||
| * console.log('This file name is too long'); | ||
| * callback('File name too long'); | ||
| * } else { | ||
| * // Do work to process file here | ||
| * console.log('File processed'); | ||
| * callback(); | ||
| * // Error Handling | ||
| * async.each(fileList, deleteFile) | ||
| * .then( () => { | ||
| * console.log('All files have been deleted successfully'); | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4/file2.txt does not exist | ||
| * // dir1/file1.txt could have been deleted | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * await async.each(files, deleteFile); | ||
| * } | ||
| * }, function(err) { | ||
| * // if any of the file processing produced an error, err would equal that error | ||
| * if( err ) { | ||
| * // One of the iterations produced an error. | ||
| * // All processing will now stop. | ||
| * console.log('A file failed to process'); | ||
| * } else { | ||
| * console.log('All files have been processed successfully'); | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * }); | ||
| * } | ||
| * | ||
| * // Error Handling | ||
| * async () => { | ||
| * try { | ||
| * await async.each(withMissingFileList, deleteFile); | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * // since dir4/file2.txt does not exist | ||
| * // dir1/file1.txt could have been deleted | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -84,0 +125,0 @@ function eachLimit(coll, iteratee, callback) { |
@@ -91,8 +91,15 @@ 'use strict'; | ||
| * | ||
| * var obj = {dev: "/dev.json", test: "/test.json", prod: "/prod.json"}; | ||
| * var configs = {}; | ||
| * // dev.json is a file containing a valid json object config for dev environment | ||
| * // dev.json is a file containing a valid json object config for test environment | ||
| * // prod.json is a file containing a valid json object config for prod environment | ||
| * // invalid.json is a file with a malformed json object | ||
| * | ||
| * async.forEachOf(obj, function (value, key, callback) { | ||
| * fs.readFile(__dirname + value, "utf8", function (err, data) { | ||
| * if (err) return callback(err); | ||
| * let configs = {}; //global variable | ||
| * let validConfigFileMap = {dev: 'dev.json', test: 'test.json', prod: 'prod.json'}; | ||
| * let invalidConfigFileMap = {dev: 'dev.json', test: 'test.json', invalid: 'invalid.json'}; | ||
| * | ||
| * // asynchronous function that reads a json file and parses the contents as json object | ||
| * function parseFile(file, key, callback) { | ||
| * fs.readFile(file, "utf8", function(err, data) { | ||
| * if (err) return calback(err); | ||
| * try { | ||
@@ -105,7 +112,69 @@ * configs[key] = JSON.parse(data); | ||
| * }); | ||
| * }, function (err) { | ||
| * if (err) console.error(err.message); | ||
| * // configs is now a map of JSON data | ||
| * doSomethingWith(configs); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.forEachOf(validConfigFileMap, parseFile, function (err) { | ||
| * if (err) { | ||
| * console.error(err); | ||
| * } else { | ||
| * console.log(configs); | ||
| * // configs is now a map of JSON data, e.g. | ||
| * // { dev: //parsed dev.json, test: //parsed test.json, prod: //parsed prod.json} | ||
| * } | ||
| * }); | ||
| * | ||
| * //Error handing | ||
| * async.forEachOf(invalidConfigFileMap, parseFile, function (err) { | ||
| * if (err) { | ||
| * console.error(err); | ||
| * // JSON parse error exception | ||
| * } else { | ||
| * console.log(configs); | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.forEachOf(validConfigFileMap, parseFile) | ||
| * .then( () => { | ||
| * console.log(configs); | ||
| * // configs is now a map of JSON data, e.g. | ||
| * // { dev: //parsed dev.json, test: //parsed test.json, prod: //parsed prod.json} | ||
| * }).catch( err => { | ||
| * console.error(err); | ||
| * }); | ||
| * | ||
| * //Error handing | ||
| * async.forEachOf(invalidConfigFileMap, parseFile) | ||
| * .then( () => { | ||
| * console.log(configs); | ||
| * }).catch( err => { | ||
| * console.error(err); | ||
| * // JSON parse error exception | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.forEachOf(validConfigFileMap, parseFile); | ||
| * console.log(configs); | ||
| * // configs is now a map of JSON data, e.g. | ||
| * // { dev: //parsed dev.json, test: //parsed test.json, prod: //parsed prod.json} | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * //Error handing | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.forEachOf(invalidConfigFileMap, parseFile); | ||
| * console.log(configs); | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * // JSON parse error exception | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -112,0 +181,0 @@ function eachOf(coll, iteratee, callback) { |
@@ -41,11 +41,65 @@ 'use strict'; | ||
| * | ||
| * async.groupBy(['userId1', 'userId2', 'userId3'], function(userId, callback) { | ||
| * db.findById(userId, function(err, user) { | ||
| * if (err) return callback(err); | ||
| * return callback(null, user.age); | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * // dir4 does not exist | ||
| * | ||
| * const files = ['dir1/file1.txt','dir2','dir4'] | ||
| * | ||
| * // asynchronous function that detects file type as none, file, or directory | ||
| * function detectFile(file, callback) { | ||
| * fs.stat(file, function(err, stat) { | ||
| * if (err) { | ||
| * return callback(null, 'none'); | ||
| * } | ||
| * callback(null, stat.isDirectory() ? 'directory' : 'file'); | ||
| * }); | ||
| * }, function(err, result) { | ||
| * // result is object containing the userIds grouped by age | ||
| * // e.g. { 30: ['userId1', 'userId3'], 42: ['userId2']}; | ||
| * } | ||
| * | ||
| * //Using callbacks | ||
| * async.groupBy(files, detectFile, function(err, result) { | ||
| * if(err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(result); | ||
| * // { | ||
| * // file: [ 'dir1/file1.txt' ], | ||
| * // none: [ 'dir4' ], | ||
| * // directory: [ 'dir2'] | ||
| * // } | ||
| * // result is object containing the files grouped by type | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.groupBy(files, detectFile) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // { | ||
| * // file: [ 'dir1/file1.txt' ], | ||
| * // none: [ 'dir4' ], | ||
| * // directory: [ 'dir2'] | ||
| * // } | ||
| * // result is object containing the files grouped by type | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.groupBy(files, detectFile); | ||
| * console.log(result); | ||
| * // { | ||
| * // file: [ 'dir1/file1.txt' ], | ||
| * // none: [ 'dir4' ], | ||
| * // directory: [ 'dir2'] | ||
| * // } | ||
| * // result is object containing the files grouped by type | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -52,0 +106,0 @@ function groupBy(coll, iteratee, callback) { |
@@ -29,3 +29,3 @@ 'use strict'; | ||
| * @param {Function} [callback] - A callback which is called when all `iteratee` | ||
| * functions have finished, or an error occurs. Result is an `Object` whoses | ||
| * functions have finished, or an error occurs. Result is an `Object` whose | ||
| * properties are arrays of values which returned the corresponding key. | ||
@@ -32,0 +32,0 @@ * @returns {Promise} a promise, if no callback is passed |
@@ -48,3 +48,3 @@ 'use strict'; | ||
| * The `iteratee` should complete with the next state of the reduction. | ||
| * If the iteratee complete with an error, the reduction is stopped and the | ||
| * If the iteratee completes with an error, the reduction is stopped and the | ||
| * main `callback` is immediately called with the error. | ||
@@ -58,10 +58,86 @@ * Invoked with (memo, item, callback). | ||
| * | ||
| * async.reduce([1,2,3], 0, function(memo, item, callback) { | ||
| * // pointless async: | ||
| * process.nextTick(function() { | ||
| * callback(null, memo + item) | ||
| * // file1.txt is a file that is 1000 bytes in size | ||
| * // file2.txt is a file that is 2000 bytes in size | ||
| * // file3.txt is a file that is 3000 bytes in size | ||
| * // file4.txt does not exist | ||
| * | ||
| * const fileList = ['file1.txt','file2.txt','file3.txt']; | ||
| * const withMissingFileList = ['file1.txt','file2.txt','file3.txt', 'file4.txt']; | ||
| * | ||
| * // asynchronous function that computes the file size in bytes | ||
| * // file size is added to the memoized value, then returned | ||
| * function getFileSizeInBytes(memo, file, callback) { | ||
| * fs.stat(file, function(err, stat) { | ||
| * if (err) { | ||
| * return callback(err); | ||
| * } | ||
| * callback(null, memo + stat.size); | ||
| * }); | ||
| * }, function(err, result) { | ||
| * // result is now equal to the last value of memo, which is 6 | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.reduce(fileList, 0, getFileSizeInBytes, function(err, result) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(result); | ||
| * // 6000 | ||
| * // which is the sum of the file sizes of the three files | ||
| * } | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.reduce(withMissingFileList, 0, getFileSizeInBytes, function(err, result) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } else { | ||
| * console.log(result); | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.reduce(fileList, 0, getFileSizeInBytes) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // 6000 | ||
| * // which is the sum of the file sizes of the three files | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.reduce(withMissingFileList, 0, getFileSizeInBytes) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.reduce(fileList, 0, getFileSizeInBytes); | ||
| * console.log(result); | ||
| * // 6000 | ||
| * // which is the sum of the file sizes of the three files | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * // Error Handling | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.reduce(withMissingFileList, 0, getFileSizeInBytes); | ||
| * console.log(result); | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -68,0 +144,0 @@ function reduce(coll, memo, iteratee, callback) { |
@@ -16,4 +16,7 @@ 'use strict'; | ||
| return (fn, ...args) => (0, _wrapAsync2.default)(fn)(...args, (err, ...resultArgs) => { | ||
| /* istanbul ignore else */ | ||
| if (typeof console === 'object') { | ||
| /* istanbul ignore else */ | ||
| if (err) { | ||
| /* istanbul ignore else */ | ||
| if (console.error) { | ||
@@ -23,2 +26,3 @@ console.error(err); | ||
| } else if (console[name]) { | ||
| /* istanbul ignore else */ | ||
| resultArgs.forEach(x => console[name](x)); | ||
@@ -25,0 +29,0 @@ } |
@@ -9,2 +9,3 @@ 'use strict'; | ||
| exports.wrap = wrap; | ||
| var hasQueueMicrotask = exports.hasQueueMicrotask = typeof queueMicrotask === 'function' && queueMicrotask; | ||
| var hasSetImmediate = exports.hasSetImmediate = typeof setImmediate === 'function' && setImmediate; | ||
@@ -23,3 +24,5 @@ var hasNextTick = exports.hasNextTick = typeof process === 'object' && typeof process.nextTick === 'function'; | ||
| if (hasSetImmediate) { | ||
| if (hasQueueMicrotask) { | ||
| _defer = queueMicrotask; | ||
| } else if (hasSetImmediate) { | ||
| _defer = setImmediate; | ||
@@ -26,0 +29,0 @@ } else if (hasNextTick) { |
84
map.js
@@ -54,5 +54,85 @@ 'use strict'; | ||
| * | ||
| * async.map(['file1','file2','file3'], fs.stat, function(err, results) { | ||
| * // results is now an array of stats for each file | ||
| * // file1.txt is a file that is 1000 bytes in size | ||
| * // file2.txt is a file that is 2000 bytes in size | ||
| * // file3.txt is a file that is 3000 bytes in size | ||
| * // file4.txt does not exist | ||
| * | ||
| * const fileList = ['file1.txt','file2.txt','file3.txt']; | ||
| * const withMissingFileList = ['file1.txt','file2.txt','file4.txt']; | ||
| * | ||
| * // asynchronous function that returns the file size in bytes | ||
| * function getFileSizeInBytes(file, callback) { | ||
| * fs.stat(file, function(err, stat) { | ||
| * if (err) { | ||
| * return callback(err); | ||
| * } | ||
| * callback(null, stat.size); | ||
| * }); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.map(fileList, getFileSizeInBytes, function(err, results) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(results); | ||
| * // results is now an array of the file size in bytes for each file, e.g. | ||
| * // [ 1000, 2000, 3000] | ||
| * } | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.map(withMissingFileList, getFileSizeInBytes, function(err, results) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } else { | ||
| * console.log(results); | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.map(fileList, getFileSizeInBytes) | ||
| * .then( results => { | ||
| * console.log(results); | ||
| * // results is now an array of the file size in bytes for each file, e.g. | ||
| * // [ 1000, 2000, 3000] | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.map(withMissingFileList, getFileSizeInBytes) | ||
| * .then( results => { | ||
| * console.log(results); | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.map(fileList, getFileSizeInBytes); | ||
| * console.log(results); | ||
| * // results is now an array of the file size in bytes for each file, e.g. | ||
| * // [ 1000, 2000, 3000] | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * // Error Handling | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.map(withMissingFileList, getFileSizeInBytes); | ||
| * console.log(results); | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -59,0 +139,0 @@ function map(coll, iteratee, callback) { |
112
mapValues.js
@@ -44,16 +44,106 @@ 'use strict'; | ||
| * | ||
| * async.mapValues({ | ||
| * f1: 'file1', | ||
| * f2: 'file2', | ||
| * f3: 'file3' | ||
| * }, function (file, key, callback) { | ||
| * fs.stat(file, callback); | ||
| * }, function(err, result) { | ||
| * // result is now a map of stats for each file, e.g. | ||
| * // file1.txt is a file that is 1000 bytes in size | ||
| * // file2.txt is a file that is 2000 bytes in size | ||
| * // file3.txt is a file that is 3000 bytes in size | ||
| * // file4.txt does not exist | ||
| * | ||
| * const fileMap = { | ||
| * f1: 'file1.txt', | ||
| * f2: 'file2.txt', | ||
| * f3: 'file3.txt' | ||
| * }; | ||
| * | ||
| * const withMissingFileMap = { | ||
| * f1: 'file1.txt', | ||
| * f2: 'file2.txt', | ||
| * f3: 'file4.txt' | ||
| * }; | ||
| * | ||
| * // asynchronous function that returns the file size in bytes | ||
| * function getFileSizeInBytes(file, key, callback) { | ||
| * fs.stat(file, function(err, stat) { | ||
| * if (err) { | ||
| * return callback(err); | ||
| * } | ||
| * callback(null, stat.size); | ||
| * }); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.mapValues(fileMap, getFileSizeInBytes, function(err, result) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(result); | ||
| * // result is now a map of file size in bytes for each file, e.g. | ||
| * // { | ||
| * // f1: 1000, | ||
| * // f2: 2000, | ||
| * // f3: 3000 | ||
| * // } | ||
| * } | ||
| * }); | ||
| * | ||
| * // Error handling | ||
| * async.mapValues(withMissingFileMap, getFileSizeInBytes, function(err, result) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } else { | ||
| * console.log(result); | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.mapValues(fileMap, getFileSizeInBytes) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // result is now a map of file size in bytes for each file, e.g. | ||
| * // { | ||
| * // f1: [stats for file1], | ||
| * // f2: [stats for file2], | ||
| * // f3: [stats for file3] | ||
| * // f1: 1000, | ||
| * // f2: 2000, | ||
| * // f3: 3000 | ||
| * // } | ||
| * }).catch (err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.mapValues(withMissingFileMap, getFileSizeInBytes) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * }).catch (err => { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.mapValues(fileMap, getFileSizeInBytes); | ||
| * console.log(result); | ||
| * // result is now a map of file size in bytes for each file, e.g. | ||
| * // { | ||
| * // f1: 1000, | ||
| * // f2: 2000, | ||
| * // f3: 3000 | ||
| * // } | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * // Error Handling | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.mapValues(withMissingFileMap, getFileSizeInBytes); | ||
| * console.log(result); | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -60,0 +150,0 @@ function mapValues(obj, iteratee, callback) { |
| { | ||
| "name": "async", | ||
| "description": "Higher-order functions and common patterns for asynchronous code", | ||
| "version": "3.2.0", | ||
| "version": "3.2.1", | ||
| "main": "dist/async.js", | ||
@@ -6,0 +6,0 @@ "author": "Caolan McMahon", |
@@ -54,2 +54,4 @@ 'use strict'; | ||
| * @example | ||
| * | ||
| * //Using Callbacks | ||
| * async.parallel([ | ||
@@ -66,6 +68,5 @@ * function(callback) { | ||
| * } | ||
| * ], | ||
| * // optional callback | ||
| * function(err, results) { | ||
| * // the results array will equal ['one','two'] even though | ||
| * ], function(err, results) { | ||
| * console.log(results); | ||
| * // results is equal to ['one','two'] even though | ||
| * // the second function had a shorter timeout. | ||
@@ -87,4 +88,92 @@ * }); | ||
| * }, function(err, results) { | ||
| * // results is now equals to: {one: 1, two: 2} | ||
| * console.log(results); | ||
| * // results is equal to: { one: 1, two: 2 } | ||
| * }); | ||
| * | ||
| * //Using Promises | ||
| * async.parallel([ | ||
| * function(callback) { | ||
| * setTimeout(function() { | ||
| * callback(null, 'one'); | ||
| * }, 200); | ||
| * }, | ||
| * function(callback) { | ||
| * setTimeout(function() { | ||
| * callback(null, 'two'); | ||
| * }, 100); | ||
| * } | ||
| * ]).then(results => { | ||
| * console.log(results); | ||
| * // results is equal to ['one','two'] even though | ||
| * // the second function had a shorter timeout. | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // an example using an object instead of an array | ||
| * async.parallel({ | ||
| * one: function(callback) { | ||
| * setTimeout(function() { | ||
| * callback(null, 1); | ||
| * }, 200); | ||
| * }, | ||
| * two: function(callback) { | ||
| * setTimeout(function() { | ||
| * callback(null, 2); | ||
| * }, 100); | ||
| * } | ||
| * }).then(results => { | ||
| * console.log(results); | ||
| * // results is equal to: { one: 1, two: 2 } | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * //Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.parallel([ | ||
| * function(callback) { | ||
| * setTimeout(function() { | ||
| * callback(null, 'one'); | ||
| * }, 200); | ||
| * }, | ||
| * function(callback) { | ||
| * setTimeout(function() { | ||
| * callback(null, 'two'); | ||
| * }, 100); | ||
| * } | ||
| * ]); | ||
| * console.log(results); | ||
| * // results is equal to ['one','two'] even though | ||
| * // the second function had a shorter timeout. | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * // an example using an object instead of an array | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.parallel({ | ||
| * one: function(callback) { | ||
| * setTimeout(function() { | ||
| * callback(null, 1); | ||
| * }, 200); | ||
| * }, | ||
| * two: function(callback) { | ||
| * setTimeout(function() { | ||
| * callback(null, 2); | ||
| * }, 100); | ||
| * } | ||
| * }); | ||
| * console.log(results); | ||
| * // results is equal to: { one: 1, two: 2 } | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -91,0 +180,0 @@ function parallel(tasks, callback) { |
@@ -10,2 +10,3 @@ 'use strict'; | ||
| var q = (0, _queue2.default)(worker, concurrency); | ||
| var processingScheduled = false; | ||
@@ -38,3 +39,9 @@ q._tasks = new _Heap2.default(); | ||
| (0, _setImmediate2.default)(q.process); | ||
| if (!processingScheduled) { | ||
| processingScheduled = true; | ||
| (0, _setImmediate2.default)(() => { | ||
| processingScheduled = false; | ||
| q.process(); | ||
| }); | ||
| } | ||
| }; | ||
@@ -41,0 +48,0 @@ |
@@ -54,3 +54,3 @@ 'use strict'; | ||
| * a promise that rejects if an error occurs. | ||
| * @property {AsyncFunction} unshirtAsync - the same as `q.unshift`, except this returns | ||
| * @property {AsyncFunction} unshiftAsync - the same as `q.unshift`, except this returns | ||
| * a promise that rejects if an error occurs. | ||
@@ -94,3 +94,3 @@ * @property {Function} remove - remove items from the queue that match a test | ||
| * @example | ||
| * const q = aync.queue(worker, 2) | ||
| * const q = async.queue(worker, 2) | ||
| * q.push(item1) | ||
@@ -97,0 +97,0 @@ * q.push(item2) |
@@ -48,3 +48,3 @@ 'use strict'; | ||
| * The `iteratee` should complete with the next state of the reduction. | ||
| * If the iteratee complete with an error, the reduction is stopped and the | ||
| * If the iteratee completes with an error, the reduction is stopped and the | ||
| * main `callback` is immediately called with the error. | ||
@@ -58,10 +58,86 @@ * Invoked with (memo, item, callback). | ||
| * | ||
| * async.reduce([1,2,3], 0, function(memo, item, callback) { | ||
| * // pointless async: | ||
| * process.nextTick(function() { | ||
| * callback(null, memo + item) | ||
| * // file1.txt is a file that is 1000 bytes in size | ||
| * // file2.txt is a file that is 2000 bytes in size | ||
| * // file3.txt is a file that is 3000 bytes in size | ||
| * // file4.txt does not exist | ||
| * | ||
| * const fileList = ['file1.txt','file2.txt','file3.txt']; | ||
| * const withMissingFileList = ['file1.txt','file2.txt','file3.txt', 'file4.txt']; | ||
| * | ||
| * // asynchronous function that computes the file size in bytes | ||
| * // file size is added to the memoized value, then returned | ||
| * function getFileSizeInBytes(memo, file, callback) { | ||
| * fs.stat(file, function(err, stat) { | ||
| * if (err) { | ||
| * return callback(err); | ||
| * } | ||
| * callback(null, memo + stat.size); | ||
| * }); | ||
| * }, function(err, result) { | ||
| * // result is now equal to the last value of memo, which is 6 | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.reduce(fileList, 0, getFileSizeInBytes, function(err, result) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(result); | ||
| * // 6000 | ||
| * // which is the sum of the file sizes of the three files | ||
| * } | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.reduce(withMissingFileList, 0, getFileSizeInBytes, function(err, result) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } else { | ||
| * console.log(result); | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.reduce(fileList, 0, getFileSizeInBytes) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // 6000 | ||
| * // which is the sum of the file sizes of the three files | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Error Handling | ||
| * async.reduce(withMissingFileList, 0, getFileSizeInBytes) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.reduce(fileList, 0, getFileSizeInBytes); | ||
| * console.log(result); | ||
| * // 6000 | ||
| * // which is the sum of the file sizes of the three files | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * // Error Handling | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.reduce(withMissingFileList, 0, getFileSizeInBytes); | ||
| * console.log(result); | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -68,0 +144,0 @@ function reduce(coll, memo, iteratee, callback) { |
@@ -29,3 +29,3 @@ 'use strict'; | ||
| * The `iteratee` should complete with the next state of the reduction. | ||
| * If the iteratee complete with an error, the reduction is stopped and the | ||
| * If the iteratee completes with an error, the reduction is stopped and the | ||
| * main `callback` is immediately called with the error. | ||
@@ -32,0 +32,0 @@ * Invoked with (memo, item, callback). |
@@ -40,10 +40,44 @@ 'use strict'; | ||
| * | ||
| * async.reject(['file1','file2','file3'], function(filePath, callback) { | ||
| * fs.access(filePath, function(err) { | ||
| * callback(null, !err) | ||
| * }); | ||
| * }, function(err, results) { | ||
| * // results now equals an array of missing files | ||
| * createFiles(results); | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * | ||
| * const fileList = ['dir1/file1.txt','dir2/file3.txt','dir3/file6.txt']; | ||
| * | ||
| * // asynchronous function that checks if a file exists | ||
| * function fileExists(file, callback) { | ||
| * fs.access(file, fs.constants.F_OK, (err) => { | ||
| * callback(null, !err); | ||
| * }); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.reject(fileList, fileExists, function(err, results) { | ||
| * // [ 'dir3/file6.txt' ] | ||
| * // results now equals an array of the non-existing files | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.reject(fileList, fileExists) | ||
| * .then( results => { | ||
| * console.log(results); | ||
| * // [ 'dir3/file6.txt' ] | ||
| * // results now equals an array of the non-existing files | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.reject(fileList, fileExists); | ||
| * console.log(results); | ||
| * // [ 'dir3/file6.txt' ] | ||
| * // results now equals an array of the non-existing files | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -50,0 +84,0 @@ function reject(coll, iteratee, callback) { |
@@ -41,9 +41,49 @@ 'use strict'; | ||
| * | ||
| * async.filter(['file1','file2','file3'], function(filePath, callback) { | ||
| * fs.access(filePath, function(err) { | ||
| * callback(null, !err) | ||
| * }); | ||
| * }, function(err, results) { | ||
| * // results now equals an array of the existing files | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * | ||
| * const files = ['dir1/file1.txt','dir2/file3.txt','dir3/file6.txt']; | ||
| * | ||
| * // asynchronous function that checks if a file exists | ||
| * function fileExists(file, callback) { | ||
| * fs.access(file, fs.constants.F_OK, (err) => { | ||
| * callback(null, !err); | ||
| * }); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.filter(files, fileExists, function(err, results) { | ||
| * if(err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(results); | ||
| * // [ 'dir1/file1.txt', 'dir2/file3.txt' ] | ||
| * // results is now an array of the existing files | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.filter(files, fileExists) | ||
| * .then(results => { | ||
| * console.log(results); | ||
| * // [ 'dir1/file1.txt', 'dir2/file3.txt' ] | ||
| * // results is now an array of the existing files | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.filter(files, fileExists); | ||
| * console.log(results); | ||
| * // [ 'dir1/file1.txt', 'dir2/file3.txt' ] | ||
| * // results is now an array of the existing files | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -50,0 +90,0 @@ function filter(coll, iteratee, callback) { |
120
series.js
@@ -53,25 +53,33 @@ 'use strict'; | ||
| * @example | ||
| * | ||
| * //Using Callbacks | ||
| * async.series([ | ||
| * function(callback) { | ||
| * // do some stuff ... | ||
| * callback(null, 'one'); | ||
| * setTimeout(function() { | ||
| * // do some async task | ||
| * callback(null, 'one'); | ||
| * }, 200); | ||
| * }, | ||
| * function(callback) { | ||
| * // do some more stuff ... | ||
| * callback(null, 'two'); | ||
| * setTimeout(function() { | ||
| * // then do another async task | ||
| * callback(null, 'two'); | ||
| * }, 100); | ||
| * } | ||
| * ], | ||
| * // optional callback | ||
| * function(err, results) { | ||
| * // results is now equal to ['one', 'two'] | ||
| * ], function(err, results) { | ||
| * console.log(results); | ||
| * // results is equal to ['one','two'] | ||
| * }); | ||
| * | ||
| * // an example using objects instead of arrays | ||
| * async.series({ | ||
| * one: function(callback) { | ||
| * setTimeout(function() { | ||
| * // do some async task | ||
| * callback(null, 1); | ||
| * }, 200); | ||
| * }, | ||
| * two: function(callback){ | ||
| * two: function(callback) { | ||
| * setTimeout(function() { | ||
| * // then do another async task | ||
| * callback(null, 2); | ||
@@ -81,4 +89,96 @@ * }, 100); | ||
| * }, function(err, results) { | ||
| * // results is now equal to: {one: 1, two: 2} | ||
| * console.log(results); | ||
| * // results is equal to: { one: 1, two: 2 } | ||
| * }); | ||
| * | ||
| * //Using Promises | ||
| * async.series([ | ||
| * function(callback) { | ||
| * setTimeout(function() { | ||
| * callback(null, 'one'); | ||
| * }, 200); | ||
| * }, | ||
| * function(callback) { | ||
| * setTimeout(function() { | ||
| * callback(null, 'two'); | ||
| * }, 100); | ||
| * } | ||
| * ]).then(results => { | ||
| * console.log(results); | ||
| * // results is equal to ['one','two'] | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // an example using an object instead of an array | ||
| * async.series({ | ||
| * one: function(callback) { | ||
| * setTimeout(function() { | ||
| * // do some async task | ||
| * callback(null, 1); | ||
| * }, 200); | ||
| * }, | ||
| * two: function(callback) { | ||
| * setTimeout(function() { | ||
| * // then do another async task | ||
| * callback(null, 2); | ||
| * }, 100); | ||
| * } | ||
| * }).then(results => { | ||
| * console.log(results); | ||
| * // results is equal to: { one: 1, two: 2 } | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * //Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.series([ | ||
| * function(callback) { | ||
| * setTimeout(function() { | ||
| * // do some async task | ||
| * callback(null, 'one'); | ||
| * }, 200); | ||
| * }, | ||
| * function(callback) { | ||
| * setTimeout(function() { | ||
| * // then do another async task | ||
| * callback(null, 'two'); | ||
| * }, 100); | ||
| * } | ||
| * ]); | ||
| * console.log(results); | ||
| * // results is equal to ['one','two'] | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * // an example using an object instead of an array | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.parallel({ | ||
| * one: function(callback) { | ||
| * setTimeout(function() { | ||
| * // do some async task | ||
| * callback(null, 1); | ||
| * }, 200); | ||
| * }, | ||
| * two: function(callback) { | ||
| * setTimeout(function() { | ||
| * // then do another async task | ||
| * callback(null, 2); | ||
| * }, 100); | ||
| * } | ||
| * }); | ||
| * console.log(results); | ||
| * // results is equal to: { one: 1, two: 2 } | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -85,0 +185,0 @@ function series(tasks, callback) { |
78
some.js
@@ -44,9 +44,75 @@ 'use strict'; | ||
| * | ||
| * async.some(['file1','file2','file3'], function(filePath, callback) { | ||
| * fs.access(filePath, function(err) { | ||
| * callback(null, !err) | ||
| * }); | ||
| * }, function(err, result) { | ||
| * // if result is true then at least one of the files exists | ||
| * // dir1 is a directory that contains file1.txt, file2.txt | ||
| * // dir2 is a directory that contains file3.txt, file4.txt | ||
| * // dir3 is a directory that contains file5.txt | ||
| * // dir4 does not exist | ||
| * | ||
| * // asynchronous function that checks if a file exists | ||
| * function fileExists(file, callback) { | ||
| * fs.access(file, fs.constants.F_OK, (err) => { | ||
| * callback(null, !err); | ||
| * }); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.some(['dir1/missing.txt','dir2/missing.txt','dir3/file5.txt'], fileExists, | ||
| * function(err, result) { | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since some file in the list exists | ||
| * } | ||
| *); | ||
| * | ||
| * async.some(['dir1/missing.txt','dir2/missing.txt','dir4/missing.txt'], fileExists, | ||
| * function(err, result) { | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since none of the files exists | ||
| * } | ||
| *); | ||
| * | ||
| * // Using Promises | ||
| * async.some(['dir1/missing.txt','dir2/missing.txt','dir3/file5.txt'], fileExists) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since some file in the list exists | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * async.some(['dir1/missing.txt','dir2/missing.txt','dir4/missing.txt'], fileExists) | ||
| * .then( result => { | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since none of the files exists | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.some(['dir1/missing.txt','dir2/missing.txt','dir3/file5.txt'], fileExists); | ||
| * console.log(result); | ||
| * // true | ||
| * // result is true since some file in the list exists | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.some(['dir1/missing.txt','dir2/missing.txt','dir4/missing.txt'], fileExists); | ||
| * console.log(result); | ||
| * // false | ||
| * // result is false since none of the files exists | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -53,0 +119,0 @@ function some(coll, iteratee, callback) { |
134
sortBy.js
@@ -43,11 +43,30 @@ 'use strict'; | ||
| * | ||
| * async.sortBy(['file1','file2','file3'], function(file, callback) { | ||
| * fs.stat(file, function(err, stats) { | ||
| * callback(err, stats.mtime); | ||
| * // bigfile.txt is a file that is 251100 bytes in size | ||
| * // mediumfile.txt is a file that is 11000 bytes in size | ||
| * // smallfile.txt is a file that is 121 bytes in size | ||
| * | ||
| * // asynchronous function that returns the file size in bytes | ||
| * function getFileSizeInBytes(file, callback) { | ||
| * fs.stat(file, function(err, stat) { | ||
| * if (err) { | ||
| * return callback(err); | ||
| * } | ||
| * callback(null, stat.size); | ||
| * }); | ||
| * }, function(err, results) { | ||
| * // results is now the original array of files sorted by | ||
| * // modified date | ||
| * }); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.sortBy(['mediumfile.txt','smallfile.txt','bigfile.txt'], getFileSizeInBytes, | ||
| * function(err, results) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(results); | ||
| * // results is now the original array of files sorted by | ||
| * // file size (ascending by default), e.g. | ||
| * // [ 'smallfile.txt', 'mediumfile.txt', 'bigfile.txt'] | ||
| * } | ||
| * } | ||
| * ); | ||
| * | ||
| * // By modifying the callback parameter the | ||
@@ -57,14 +76,97 @@ * // sorting order can be influenced: | ||
| * // ascending order | ||
| * async.sortBy([1,9,3,5], function(x, callback) { | ||
| * callback(null, x); | ||
| * }, function(err,result) { | ||
| * // result callback | ||
| * }); | ||
| * async.sortBy(['mediumfile.txt','smallfile.txt','bigfile.txt'], function(file, callback) { | ||
| * getFileSizeInBytes(file, function(getFileSizeErr, fileSize) { | ||
| * if (getFileSizeErr) return callback(getFileSizeErr); | ||
| * callback(null, fileSize); | ||
| * }); | ||
| * }, function(err, results) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(results); | ||
| * // results is now the original array of files sorted by | ||
| * // file size (ascending by default), e.g. | ||
| * // [ 'smallfile.txt', 'mediumfile.txt', 'bigfile.txt'] | ||
| * } | ||
| * } | ||
| * ); | ||
| * | ||
| * // descending order | ||
| * async.sortBy([1,9,3,5], function(x, callback) { | ||
| * callback(null, x*-1); //<- x*-1 instead of x, turns the order around | ||
| * }, function(err,result) { | ||
| * // result callback | ||
| * async.sortBy(['bigfile.txt','mediumfile.txt','smallfile.txt'], function(file, callback) { | ||
| * getFileSizeInBytes(file, function(getFileSizeErr, fileSize) { | ||
| * if (getFileSizeErr) { | ||
| * return callback(getFileSizeErr); | ||
| * } | ||
| * callback(null, fileSize * -1); | ||
| * }); | ||
| * }, function(err, results) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(results); | ||
| * // results is now the original array of files sorted by | ||
| * // file size (ascending by default), e.g. | ||
| * // [ 'bigfile.txt', 'mediumfile.txt', 'smallfile.txt'] | ||
| * } | ||
| * } | ||
| * ); | ||
| * | ||
| * // Error handling | ||
| * async.sortBy(['mediumfile.txt','smallfile.txt','missingfile.txt'], getFileSizeInBytes, | ||
| * function(err, results) { | ||
| * if (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } else { | ||
| * console.log(results); | ||
| * } | ||
| * } | ||
| * ); | ||
| * | ||
| * // Using Promises | ||
| * async.sortBy(['mediumfile.txt','smallfile.txt','bigfile.txt'], getFileSizeInBytes) | ||
| * .then( results => { | ||
| * console.log(results); | ||
| * // results is now the original array of files sorted by | ||
| * // file size (ascending by default), e.g. | ||
| * // [ 'smallfile.txt', 'mediumfile.txt', 'bigfile.txt'] | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Error handling | ||
| * async.sortBy(['mediumfile.txt','smallfile.txt','missingfile.txt'], getFileSizeInBytes) | ||
| * .then( results => { | ||
| * console.log(results); | ||
| * }).catch( err => { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * (async () => { | ||
| * try { | ||
| * let results = await async.sortBy(['bigfile.txt','mediumfile.txt','smallfile.txt'], getFileSizeInBytes); | ||
| * console.log(results); | ||
| * // results is now the original array of files sorted by | ||
| * // file size (ascending by default), e.g. | ||
| * // [ 'smallfile.txt', 'mediumfile.txt', 'bigfile.txt'] | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * })(); | ||
| * | ||
| * // Error handling | ||
| * async () => { | ||
| * try { | ||
| * let results = await async.sortBy(['missingfile.txt','mediumfile.txt','smallfile.txt'], getFileSizeInBytes); | ||
| * console.log(results); | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * // [ Error: ENOENT: no such file or directory ] | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -71,0 +173,0 @@ function sortBy(coll, iteratee, callback) { |
122
transform.js
@@ -46,22 +46,114 @@ 'use strict'; | ||
| * | ||
| * async.transform([1,2,3], function(acc, item, index, callback) { | ||
| * // pointless async: | ||
| * process.nextTick(function() { | ||
| * acc[index] = item * 2 | ||
| * callback(null) | ||
| * // file1.txt is a file that is 1000 bytes in size | ||
| * // file2.txt is a file that is 2000 bytes in size | ||
| * // file3.txt is a file that is 3000 bytes in size | ||
| * | ||
| * // helper function that returns human-readable size format from bytes | ||
| * function formatBytes(bytes, decimals = 2) { | ||
| * // implementation not included for brevity | ||
| * return humanReadbleFilesize; | ||
| * } | ||
| * | ||
| * const fileList = ['file1.txt','file2.txt','file3.txt']; | ||
| * | ||
| * // asynchronous function that returns the file size, transformed to human-readable format | ||
| * // e.g. 1024 bytes = 1KB, 1234 bytes = 1.21 KB, 1048576 bytes = 1MB, etc. | ||
| * function transformFileSize(acc, value, key, callback) { | ||
| * fs.stat(value, function(err, stat) { | ||
| * if (err) { | ||
| * return callback(err); | ||
| * } | ||
| * acc[key] = formatBytes(stat.size); | ||
| * callback(null); | ||
| * }); | ||
| * }, function(err, result) { | ||
| * // result is now equal to [2, 4, 6] | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.transform(fileList, transformFileSize, function(err, result) { | ||
| * if(err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(result); | ||
| * // [ '1000 Bytes', '1.95 KB', '2.93 KB' ] | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.transform(fileList, transformFileSize) | ||
| * .then(result => { | ||
| * console.log(result); | ||
| * // [ '1000 Bytes', '1.95 KB', '2.93 KB' ] | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * (async () => { | ||
| * try { | ||
| * let result = await async.transform(fileList, transformFileSize); | ||
| * console.log(result); | ||
| * // [ '1000 Bytes', '1.95 KB', '2.93 KB' ] | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * })(); | ||
| * | ||
| * @example | ||
| * | ||
| * async.transform({a: 1, b: 2, c: 3}, function (obj, val, key, callback) { | ||
| * setImmediate(function () { | ||
| * obj[key] = val * 2; | ||
| * callback(); | ||
| * }) | ||
| * }, function (err, result) { | ||
| * // result is equal to {a: 2, b: 4, c: 6} | ||
| * }) | ||
| * // file1.txt is a file that is 1000 bytes in size | ||
| * // file2.txt is a file that is 2000 bytes in size | ||
| * // file3.txt is a file that is 3000 bytes in size | ||
| * | ||
| * // helper function that returns human-readable size format from bytes | ||
| * function formatBytes(bytes, decimals = 2) { | ||
| * // implementation not included for brevity | ||
| * return humanReadbleFilesize; | ||
| * } | ||
| * | ||
| * const fileMap = { f1: 'file1.txt', f2: 'file2.txt', f3: 'file3.txt' }; | ||
| * | ||
| * // asynchronous function that returns the file size, transformed to human-readable format | ||
| * // e.g. 1024 bytes = 1KB, 1234 bytes = 1.21 KB, 1048576 bytes = 1MB, etc. | ||
| * function transformFileSize(acc, value, key, callback) { | ||
| * fs.stat(value, function(err, stat) { | ||
| * if (err) { | ||
| * return callback(err); | ||
| * } | ||
| * acc[key] = formatBytes(stat.size); | ||
| * callback(null); | ||
| * }); | ||
| * } | ||
| * | ||
| * // Using callbacks | ||
| * async.transform(fileMap, transformFileSize, function(err, result) { | ||
| * if(err) { | ||
| * console.log(err); | ||
| * } else { | ||
| * console.log(result); | ||
| * // { f1: '1000 Bytes', f2: '1.95 KB', f3: '2.93 KB' } | ||
| * } | ||
| * }); | ||
| * | ||
| * // Using Promises | ||
| * async.transform(fileMap, transformFileSize) | ||
| * .then(result => { | ||
| * console.log(result); | ||
| * // { f1: '1000 Bytes', f2: '1.95 KB', f3: '2.93 KB' } | ||
| * }).catch(err => { | ||
| * console.log(err); | ||
| * }); | ||
| * | ||
| * // Using async/await | ||
| * async () => { | ||
| * try { | ||
| * let result = await async.transform(fileMap, transformFileSize); | ||
| * console.log(result); | ||
| * // { f1: '1000 Bytes', f2: '1.95 KB', f3: '2.93 KB' } | ||
| * } | ||
| * catch (err) { | ||
| * console.log(err); | ||
| * } | ||
| * } | ||
| * | ||
| */ | ||
@@ -68,0 +160,0 @@ function transform(coll, accumulator, iteratee, callback) { |
@@ -44,3 +44,3 @@ 'use strict'; | ||
| * let finished = false | ||
| * async.until(function test(page, cb) { | ||
| * async.until(function test(cb) { | ||
| * cb(null, finished) | ||
@@ -47,0 +47,0 @@ * }, function iter(next) { |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
No alert changes
Improved metrics
- Total package byte prevSize
- increased by17.67%
816097
- Lines of code
- increased by25.5%
20066
No dependency changes