use only_once in a few more places

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();
                         }