1 files changed, 13 insertions, 12 deletions
diff --git a/lib/async.js b/lib/async.js
index 7dfef34..5c7f737 100755
--- a/lib/async.js
+++ b/lib/async.js
@@ -112,19 +112,20 @@
         }
         var completed = 0;
         _each(arr, function (x) {
-            iterator(x, only_once(function (err) {
-                if (err) {
-                    callback(err);
-                    callback = function () {};
-                }
-                else {
-                    completed += 1;
-                    if (completed >= arr.length) {
-                        callback(null);
-                    }
-                }
-            }));
+            iterator(x, only_once(done) );
         });
+        function done(err) {
+          if (err) {
+              callback(err);
+              callback = function () {};
+          }
+          else {
+              completed += 1;
+              if (completed >= arr.length) {
+                  callback(null);
+              }
+          }
+        }
     };
     async.forEach = async.each;