diff options
author | Caolan McMahon <caolan@caolanmcmahon.com> | 2012-05-24 00:15:09 -0700 |
---|---|---|
committer | Caolan McMahon <caolan@caolanmcmahon.com> | 2012-05-24 00:15:09 -0700 |
commit | de143e13f9aa78c45c99822a1696bab76fc4e069 (patch) | |
tree | e86d071f9dd5f9145a44bee03372fe9ccf855d39 | |
parent | 16b9271e5c684cd7729fa3906032536509e3a4a0 (diff) | |
download | async-de143e13f9aa78c45c99822a1696bab76fc4e069.tar.gz |
update indentation on forEachSeries
-rw-r--r-- | lib/async.js | 54 |
1 files changed, 27 insertions, 27 deletions
diff --git a/lib/async.js b/lib/async.js index 3010bab..4a51d28 100644 --- a/lib/async.js +++ b/lib/async.js @@ -123,41 +123,41 @@ }; iterate(); }; - + async.forEachLimit = function (arr, limit, iterator, callback) { callback = callback || function () {}; if (!arr.length || limit <= 0) { - return callback(); + return callback(); } var completed = 0; var started = 0; var running = 0; - + (function replenish () { - if (completed === arr.length) { - return callback(); - } - - while (running < limit && started < arr.length) { - started += 1; - iterator(arr[started - 1], function (err) { - if (err) { - callback(err); - callback = function () {}; - } - else { - completed += 1; - running -= 1; - if (completed === arr.length) { - callback(); - } - else { - replenish(); - } - } - }); - running += 1; - } + if (completed === arr.length) { + return callback(); + } + + while (running < limit && started < arr.length) { + started += 1; + running += 1; + iterator(arr[started - 1], function (err) { + if (err) { + callback(err); + callback = function () {}; + } + else { + completed += 1; + running -= 1; + if (completed === arr.length) { + callback(); + } + else { + replenish(); + } + } + }); + } })(); }; |