summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCaolan McMahon <caolan@caolanmcmahon.com>2012-05-24 00:15:09 -0700
committerCaolan McMahon <caolan@caolanmcmahon.com>2012-05-24 00:15:09 -0700
commitde143e13f9aa78c45c99822a1696bab76fc4e069 (patch)
treee86d071f9dd5f9145a44bee03372fe9ccf855d39
parent16b9271e5c684cd7729fa3906032536509e3a4a0 (diff)
downloadasync-de143e13f9aa78c45c99822a1696bab76fc4e069.tar.gz
update indentation on forEachSeries
-rw-r--r--lib/async.js54
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();
+ }
+ }
+ });
+ }
})();
};