summaryrefslogtreecommitdiff
path: root/lib/async.js
diff options
context:
space:
mode:
authorGraeme Yeates <yeatesgraeme@gmail.com>2015-08-01 17:48:49 -0400
committerGraeme Yeates <yeatesgraeme@gmail.com>2015-08-01 17:48:49 -0400
commitd9b860d666fd79498a45268c47bfd964c2fabefd (patch)
treea1799f2667eb8d41f44db8cc2714420e920d2995 /lib/async.js
parent0574aa90d696e22e5c870192ba8ec22e4e0e9eb2 (diff)
downloadasync-each-iter.tar.gz
Implement each as iteratoreach-iter
Diffstat (limited to 'lib/async.js')
-rw-r--r--lib/async.js30
1 files changed, 11 insertions, 19 deletions
diff --git a/lib/async.js b/lib/async.js
index 208e602..b8a2b24 100644
--- a/lib/async.js
+++ b/lib/async.js
@@ -77,12 +77,6 @@
);
}
- function _each(coll, iterator) {
- return _isArrayLike(coll) ?
- _arrayEach(coll, iterator) :
- _forEachOf(coll, iterator);
- }
-
function _arrayEach(arr, iterator) {
var index = -1,
length = arr.length;
@@ -229,24 +223,22 @@
async.forEachOf =
async.eachOf = function (object, iterator, callback) {
callback = _once(callback || noop);
- object = object || [];
- var size = _isArrayLike(object) ? object.length : _keys(object).length;
- var completed = 0;
- if (!size) {
- return callback(null);
- }
- _each(object, function (value, key) {
+
+ var nextKey = _keyIterator(object || []);
+ var key, running = 0;
+ while ((key = nextKey()) != null) {
+ running += 1;
iterator(object[key], key, only_once(done));
- });
+ }
+ if (!running) {
+ callback (null);
+ }
function done(err) {
if (err) {
callback(err);
}
- else {
- completed += 1;
- if (completed >= size) {
- callback(null);
- }
+ else if (--running <= 0) {
+ callback(null);
}
}
};