diff options
Diffstat (limited to 'lib/async.js')
| -rw-r--r-- | lib/async.js | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/lib/async.js b/lib/async.js index bfc8bdd..0589349 100644 --- a/lib/async.js +++ b/lib/async.js @@ -253,7 +253,7 @@ if (key === null) { return callback(null); } - iterator(obj[key], key, function (err) { + iterator(obj[key], key, only_once(function (err) { if (err) { callback(err); } @@ -265,7 +265,7 @@ iterate(); } } - }); + })); sync = false; } iterate(); @@ -306,7 +306,7 @@ return; } running += 1; - iterator(obj[key], key, function (err) { + iterator(obj[key], key, only_once(function (err) { running -= 1; if (err) { callback(err); @@ -315,7 +315,7 @@ else { replenish(); } - }); + })); } })(); }; @@ -880,11 +880,11 @@ var tasks = payload ? q.tasks.splice(0, payload) : q.tasks.splice(0, q.tasks.length); - + var data = _map(tasks, function (task) { return task.data; }); - + if (q.tasks.length === 0) { q.empty(); } |