Comparing version 0.2.4 to 0.2.5
@@ -86,3 +86,4 @@ | ||
complete = function(argLen, hasError) { | ||
var i = 0; | ||
var i = 0 | ||
, err; | ||
@@ -105,7 +106,11 @@ if (argLen > maxLen) maxLen = argLen; | ||
if (errCount) { | ||
i = items.length; | ||
while(i--) { | ||
if (items[i] instanceof Error) return callback(items[i]); | ||
} | ||
callback(new Error('There were '+errCount+' error(s) while processing your data!').setName('ProcessingError'), items); | ||
items.some(function(arg){ | ||
if (arg instanceof Error) { | ||
err = arg; | ||
return true; | ||
} | ||
}); | ||
if (err) callback(err); | ||
else callback(new Error('There were '+errCount+' error(s) while processing your data!').setName('ProcessingError'), items); | ||
} | ||
@@ -112,0 +117,0 @@ else callback(undefined, items); |
@@ -29,3 +29,3 @@ | ||
complete = function(index, args) { | ||
var i, a; | ||
var i, a, err; | ||
@@ -54,7 +54,11 @@ finished++; | ||
if (errCount) { | ||
i = results.length; | ||
while(i--) { | ||
if (results[i] instanceof Error) return callback(results[i]); | ||
} | ||
callback(new Error('There were '+errCount+' errors while processing your data!').setName('ProcessingError'), results); | ||
results.some(function(arg){ | ||
if (arg instanceof Error) { | ||
err = arg; | ||
return true; | ||
} | ||
}); | ||
if (err) callback(err); | ||
else callback(new Error('There were '+errCount+' errors while processing your data!').setName('ProcessingError'), results); | ||
} | ||
@@ -61,0 +65,0 @@ else callback(undefined, results); |
{ | ||
"name" : "ee-async" | ||
, "description" : "simpler control flow for asynchronous operations" | ||
, "version" : "0.2.4" | ||
, "version" : "0.2.5" | ||
, "homepage" : "https://github.com/eventEmitter/ee-async" | ||
@@ -6,0 +6,0 @@ , "author" : "Michael van der Weg <michael@eventemitter.com> (http://eventemitter.com/)" |
8776
199