diff options
| -rw-r--r-- | lib/async.js | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/lib/async.js b/lib/async.js index 439ecc9..4257f0d 100644 --- a/lib/async.js +++ b/lib/async.js @@ -215,18 +215,20 @@ var completed = 0; var started = 0; var running = 0; + var errored = false; (function replenish () { if (completed >= arr.length) { return callback(null); } - while (running < limit && started < arr.length) { + while (running < limit && started < arr.length && !errored) { started += 1; running += 1; iterator(arr[started - 1], function (err) { if (err) { callback(err); + errored = true; callback = noop; } else { |