neo-async
Advanced tools
Comparing version 2.2.0 to 2.2.2
@@ -28,3 +28,3 @@ (function(M,O){"object"===typeof exports&&"undefined"!==typeof module?O(exports):"function"===typeof define&&define.amd?define(["exports"],O):M.async?O(M.neo_async=M.neo_async||{}):O(M.async=M.async||{})})(this,function(M){function O(a){var b=function(a){var b=J(arguments,1);setTimeout(function(){a.apply(null,b)})};P="function"===typeof setImmediate?setImmediate:b;"object"===typeof process&&"function"===typeof process.nextTick?(C=/^v0.10/.test(process.version)?P:process.nextTick,$=/^v0/.test(process.version)? | ||
!0;var d=B(a)?a:[a];void 0!==a&&d.length?(n=c,h=b,Q(d,e)):q.idle()&&C(q.drain)}function g(a,b){var c=!1;return function(d,e){c&&A();c=!0;k--;for(var f,g=-1,h=m.length,l=-1,r=b.length,n=2<arguments.length,s=n&&E(arguments);++l<r;){for(f=b[l];++g<h;)m[g]===f&&(m.splice(g,1),g=h,h--);g=-1;n?f.callback.apply(f,s):f.callback(d,e);d&&a.error(d,f.data)}k<=a.concurrency-a.buffer&&a.unsaturated();0===a._tasks.length+k&&a.drain();a.process()}}function l(){for(;!q.paused&&k<q.concurrency&&q._tasks.length;){var a= | ||
q._tasks.shift();0===q._tasks.length&&q.empty();k++;m.push(a);k===q.concurrency&&q.saturated();var c=g(q,[a]);b(a.data,c)}}function r(){for(;!q.paused&&k<q.concurrency&&q._tasks.length;){for(var a=q._tasks.splice(q.payload||q._tasks.length),c=-1,d=a.length,e=Array(d);++c<d;)e[c]=a[c].data;0===q._tasks.length&&q.empty();k++;Array.prototype.push.apply(m,a);k===q.concurrency&&q.saturated();a=g(q,a);b(e,a)}}function s(){C(q.process)}if(void 0===c)c=1;else if(isNaN(c)||1>c)throw Error("Concurrency must not be zero"); | ||
q._tasks.shift();k++;m.push(a);0===q._tasks.length&&q.empty();k===q.concurrency&&q.saturated();var c=g(q,[a]);b(a.data,c)}}function r(){for(;!q.paused&&k<q.concurrency&&q._tasks.length;){for(var a=q._tasks.splice(q.payload||q._tasks.length),c=-1,d=a.length,e=Array(d);++c<d;)e[c]=a[c].data;k++;Array.prototype.push.apply(m,a);0===q._tasks.length&&q.empty();k===q.concurrency&&q.saturated();a=g(q,a);b(e,a)}}function s(){C(q.process)}if(void 0===c)c=1;else if(isNaN(c)||1>c)throw Error("Concurrency must not be zero"); | ||
var k=0,m=[],h,n,q={_tasks:new N,concurrency:c,payload:d,saturated:y,unsaturated:y,buffer:c/4,empty:y,drain:y,error:y,started:!1,paused:!1,push:function(a,b){f(a,b)},kill:function(){q.drain=y;q._tasks.empty()},unshift:function(a,b){f(a,b,!0)},process:a?l:r,length:function(){return q._tasks.length},running:function(){return k},workersList:function(){return m},idle:function(){return 0===q.length()+k},pause:function(){q.paused=!0},resume:function(){!1!==q.paused&&(q.paused=!1,K(q.concurrency<q._tasks.length? | ||
@@ -44,3 +44,3 @@ q.concurrency:q._tasks.length,s))},_worker:b};return q}function Ma(a,b,c){function d(){if(0===s.length&&0===r){if(0!==g)throw Error("async.auto task has cyclic dependencies");return c(null,l)}for(;s.length&&r<b&&c!==y;){r++;var a=s.shift();if(0===a[1])a[0](a[2]);else a[0](l,a[2])}}function e(a){Q(k[a]||[],function(a){a()});d()}"function"===typeof b&&(c=b,b=null);var f=D(a),g=f.length,l={};if(0===g)return c(null,l);var r=0,s=[],k=Object.create(null);c=z(c||y);b=b||g;R(a,function(a,b){function d(a, | ||
l&&f(null,s)}}}f=f||y;var l,r=0,s={};if(B(d))l=d.length,a(d,e,g);else if(d)if(x&&d[x])l=d.size,c(d,e,g);else if("object"===typeof d){var k=D(d);l=k.length;b(d,e,g,k)}l||f(null,{})}}(S,T,U),sb=function(a,b){return function(c,d){function e(a){return function(b,c){null===a&&A();b?(a=null,d=H(d),d(b,l)):(l[a]=2>=arguments.length?c:J(arguments,1),a=null,++r===f&&d(null,l))}}d=d||y;var f,g,l,r=0;B(c)?(f=c.length,l=Array(f),a(c,e)):c&&"object"===typeof c&&(g=D(c),f=g.length,l={},b(c,e,g));f||d(null,l)}}(function(a, | ||
b){for(var c=-1,d=a.length;++c<d;)a[c](b(c))},function(a,b,c){for(var d,e=-1,f=c.length;++e<f;)d=c[e],a[d](b(d))}),tb=La(Qa),ub=La(xa),vb=ia("log"),wb=ia("dir"),ja={VERSION:"2.2.0",each:Z,eachSeries:W,eachLimit:X,forEach:Z,forEachSeries:W,forEachLimit:X,eachOf:Z,eachOfSeries:W,eachOfLimit:X,forEachOf:Z,forEachOfSeries:W,forEachOfLimit:X,map:Qa,mapSeries:xa,mapLimit:function(a,b,c,d){function e(){h=F++;h<m&&c(a[h],k(h))}function f(){h=F++;h<m&&c(a[h],h,k(h))}function g(){!1===(t=p.next()).done&&c(t.value, | ||
b){for(var c=-1,d=a.length;++c<d;)a[c](b(c))},function(a,b,c){for(var d,e=-1,f=c.length;++e<f;)d=c[e],a[d](b(d))}),tb=La(Qa),ub=La(xa),vb=ia("log"),wb=ia("dir"),ja={VERSION:"2.2.2",each:Z,eachSeries:W,eachLimit:X,forEach:Z,forEachSeries:W,forEachLimit:X,eachOf:Z,eachOfSeries:W,eachOfLimit:X,forEachOf:Z,forEachOfSeries:W,forEachOfLimit:X,map:Qa,mapSeries:xa,mapLimit:function(a,b,c,d){function e(){h=F++;h<m&&c(a[h],k(h))}function f(){h=F++;h<m&&c(a[h],h,k(h))}function g(){!1===(t=p.next()).done&&c(t.value, | ||
k(F++))}function l(){!1===(t=p.next()).done&&c(t.value,F,k(F++))}function r(){h=F++;h<m&&c(a[q[h]],k(h))}function s(){h=F++;h<m&&(n=q[h],c(a[n],n,k(h)))}function k(a){return function(b,c){null===a&&A();b?(a=null,u=y,d=H(d),d(b,E(v))):(v[a]=c,a=null,++z===m?(u=A,d(null,v),d=A):w?C(u):(w=!0,u()),w=!1)}}d=d||y;var m,h,n,q,p,t,v,u,w=!1,F=0,z=0;B(a)?(m=a.length,u=3===c.length?f:e):a&&(x&&a[x]?(m=a.size,p=a[x](),u=3===c.length?l:g):"object"===typeof a&&(q=D(a),m=q.length,u=3===c.length?s:r));if(!m||isNaN(b)|| | ||
@@ -47,0 +47,0 @@ 1>b)return d(null,[]);v=Array(m);K(b>m?m:b,u)},mapValues:eb,mapValuesSeries:function(a,b,c){function d(){m=u;b(a[u],s)}function e(){m=u;b(a[u],u,s)}function f(){m=u;q=n.next().value;b(q,s)}function g(){m=u;q=n.next().value;b(q,u,s)}function l(){m=h[u];b(a[m],s)}function r(){m=h[u];b(a[m],m,s)}function s(a,b){a?(p=A,c=z(c),c(a,L(v))):(v[m]=b,++u===k?(p=A,c(null,v),c=A):t?C(p):(t=!0,p()),t=!1)}c=c||y;var k,m,h,n,q,p,t=!1,v={},u=0;B(a)?(k=a.length,p=3===b.length?e:d):a&&(x&&a[x]?(k=a.size,n=a[x](),p= |
@@ -28,3 +28,3 @@ (function(M,O){"object"===typeof exports&&"undefined"!==typeof module?O(exports):"function"===typeof define&&define.amd?define(["exports"],O):M.async?O(M.neo_async=M.neo_async||{}):O(M.async=M.async||{})})(this,function(M){function O(a){var b=function(a){var b=J(arguments,1);setTimeout(function(){a.apply(null,b)})};P="function"===typeof setImmediate?setImmediate:b;"object"===typeof process&&"function"===typeof process.nextTick?(C=/^v0.10/.test(process.version)?P:process.nextTick,$=/^v0/.test(process.version)? | ||
!0;var d=B(a)?a:[a];void 0!==a&&d.length?(n=c,h=b,Q(d,e)):q.idle()&&C(q.drain)}function g(a,b){var c=!1;return function(d,e){c&&A();c=!0;k--;for(var f,g=-1,h=m.length,l=-1,r=b.length,n=2<arguments.length,s=n&&E(arguments);++l<r;){for(f=b[l];++g<h;)m[g]===f&&(m.splice(g,1),g=h,h--);g=-1;n?f.callback.apply(f,s):f.callback(d,e);d&&a.error(d,f.data)}k<=a.concurrency-a.buffer&&a.unsaturated();0===a._tasks.length+k&&a.drain();a.process()}}function l(){for(;!q.paused&&k<q.concurrency&&q._tasks.length;){var a= | ||
q._tasks.shift();0===q._tasks.length&&q.empty();k++;m.push(a);k===q.concurrency&&q.saturated();var c=g(q,[a]);b(a.data,c)}}function r(){for(;!q.paused&&k<q.concurrency&&q._tasks.length;){for(var a=q._tasks.splice(q.payload||q._tasks.length),c=-1,d=a.length,e=Array(d);++c<d;)e[c]=a[c].data;0===q._tasks.length&&q.empty();k++;Array.prototype.push.apply(m,a);k===q.concurrency&&q.saturated();a=g(q,a);b(e,a)}}function s(){C(q.process)}if(void 0===c)c=1;else if(isNaN(c)||1>c)throw Error("Concurrency must not be zero"); | ||
q._tasks.shift();k++;m.push(a);0===q._tasks.length&&q.empty();k===q.concurrency&&q.saturated();var c=g(q,[a]);b(a.data,c)}}function r(){for(;!q.paused&&k<q.concurrency&&q._tasks.length;){for(var a=q._tasks.splice(q.payload||q._tasks.length),c=-1,d=a.length,e=Array(d);++c<d;)e[c]=a[c].data;k++;Array.prototype.push.apply(m,a);0===q._tasks.length&&q.empty();k===q.concurrency&&q.saturated();a=g(q,a);b(e,a)}}function s(){C(q.process)}if(void 0===c)c=1;else if(isNaN(c)||1>c)throw Error("Concurrency must not be zero"); | ||
var k=0,m=[],h,n,q={_tasks:new N,concurrency:c,payload:d,saturated:y,unsaturated:y,buffer:c/4,empty:y,drain:y,error:y,started:!1,paused:!1,push:function(a,b){f(a,b)},kill:function(){q.drain=y;q._tasks.empty()},unshift:function(a,b){f(a,b,!0)},process:a?l:r,length:function(){return q._tasks.length},running:function(){return k},workersList:function(){return m},idle:function(){return 0===q.length()+k},pause:function(){q.paused=!0},resume:function(){!1!==q.paused&&(q.paused=!1,K(q.concurrency<q._tasks.length? | ||
@@ -44,3 +44,3 @@ q.concurrency:q._tasks.length,s))},_worker:b};return q}function Ma(a,b,c){function d(){if(0===s.length&&0===r){if(0!==g)throw Error("async.auto task has cyclic dependencies");return c(null,l)}for(;s.length&&r<b&&c!==y;){r++;var a=s.shift();if(0===a[1])a[0](a[2]);else a[0](l,a[2])}}function e(a){Q(k[a]||[],function(a){a()});d()}"function"===typeof b&&(c=b,b=null);var f=D(a),g=f.length,l={};if(0===g)return c(null,l);var r=0,s=[],k=Object.create(null);c=z(c||y);b=b||g;R(a,function(a,b){function d(a, | ||
l&&f(null,s)}}}f=f||y;var l,r=0,s={};if(B(d))l=d.length,a(d,e,g);else if(d)if(x&&d[x])l=d.size,c(d,e,g);else if("object"===typeof d){var k=D(d);l=k.length;b(d,e,g,k)}l||f(null,{})}}(S,T,U),sb=function(a,b){return function(c,d){function e(a){return function(b,c){null===a&&A();b?(a=null,d=H(d),d(b,l)):(l[a]=2>=arguments.length?c:J(arguments,1),a=null,++r===f&&d(null,l))}}d=d||y;var f,g,l,r=0;B(c)?(f=c.length,l=Array(f),a(c,e)):c&&"object"===typeof c&&(g=D(c),f=g.length,l={},b(c,e,g));f||d(null,l)}}(function(a, | ||
b){for(var c=-1,d=a.length;++c<d;)a[c](b(c))},function(a,b,c){for(var d,e=-1,f=c.length;++e<f;)d=c[e],a[d](b(d))}),tb=La(Qa),ub=La(xa),vb=ia("log"),wb=ia("dir"),ja={VERSION:"2.2.0",each:Z,eachSeries:W,eachLimit:X,forEach:Z,forEachSeries:W,forEachLimit:X,eachOf:Z,eachOfSeries:W,eachOfLimit:X,forEachOf:Z,forEachOfSeries:W,forEachOfLimit:X,map:Qa,mapSeries:xa,mapLimit:function(a,b,c,d){function e(){h=F++;h<m&&c(a[h],k(h))}function f(){h=F++;h<m&&c(a[h],h,k(h))}function g(){!1===(t=p.next()).done&&c(t.value, | ||
b){for(var c=-1,d=a.length;++c<d;)a[c](b(c))},function(a,b,c){for(var d,e=-1,f=c.length;++e<f;)d=c[e],a[d](b(d))}),tb=La(Qa),ub=La(xa),vb=ia("log"),wb=ia("dir"),ja={VERSION:"2.2.2",each:Z,eachSeries:W,eachLimit:X,forEach:Z,forEachSeries:W,forEachLimit:X,eachOf:Z,eachOfSeries:W,eachOfLimit:X,forEachOf:Z,forEachOfSeries:W,forEachOfLimit:X,map:Qa,mapSeries:xa,mapLimit:function(a,b,c,d){function e(){h=F++;h<m&&c(a[h],k(h))}function f(){h=F++;h<m&&c(a[h],h,k(h))}function g(){!1===(t=p.next()).done&&c(t.value, | ||
k(F++))}function l(){!1===(t=p.next()).done&&c(t.value,F,k(F++))}function r(){h=F++;h<m&&c(a[q[h]],k(h))}function s(){h=F++;h<m&&(n=q[h],c(a[n],n,k(h)))}function k(a){return function(b,c){null===a&&A();b?(a=null,u=y,d=H(d),d(b,E(v))):(v[a]=c,a=null,++z===m?(u=A,d(null,v),d=A):w?C(u):(w=!0,u()),w=!1)}}d=d||y;var m,h,n,q,p,t,v,u,w=!1,F=0,z=0;B(a)?(m=a.length,u=3===c.length?f:e):a&&(x&&a[x]?(m=a.size,p=a[x](),u=3===c.length?l:g):"object"===typeof a&&(q=D(a),m=q.length,u=3===c.length?s:r));if(!m||isNaN(b)|| | ||
@@ -47,0 +47,0 @@ 1>b)return d(null,[]);v=Array(m);K(b>m?m:b,u)},mapValues:eb,mapValuesSeries:function(a,b,c){function d(){m=u;b(a[u],s)}function e(){m=u;b(a[u],u,s)}function f(){m=u;q=n.next().value;b(q,s)}function g(){m=u;q=n.next().value;b(q,u,s)}function l(){m=h[u];b(a[m],s)}function r(){m=h[u];b(a[m],m,s)}function s(a,b){a?(p=A,c=z(c),c(a,L(v))):(v[m]=b,++u===k?(p=A,c(null,v),c=A):t?C(p):(t=!0,p()),t=!1)}c=c||y;var k,m,h,n,q,p,t=!1,v={},u=0;B(a)?(k=a.length,p=3===b.length?e:d):a&&(x&&a[x]?(k=a.size,n=a[x](),p= |
{ | ||
"name": "neo-async", | ||
"version": "2.2.0", | ||
"version": "2.2.2", | ||
"description": "Neo-Async is thought to be used as a drop-in replacement for Async, it almost fully covers its functionality and runs faster ", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
635692