initial ensureAsync implementation

2 files changed, 29 insertions, 1 deletions

diff --git a/perf/benchmark.js b/perf/benchmark.js
index da59216..9e57fd9 100755
--- a/perf/benchmark.js
+++ b/perf/benchmark.js
@@ -129,7 +129,10 @@ function createSuite(suiteConfig) {
       });
     }, _.extend({
       versionName: versionName,
-      setup: _.partial.apply(null, [suiteConfig.setup].concat(args))
+      setup: _.partial.apply(null, [suiteConfig.setup].concat(args)),
+      onError: function (err) {
+        console.log(err.stack);
+      }
     }, benchOptions));
   }
 
@@ -143,6 +146,7 @@ function createSuite(suiteConfig) {
     var version = event.target.options.versionName;
     totalTime[version] += mean;
   })
+  .on('error', function (err) { console.error(err); })
   .on('complete', function() {
     var fastest = this.filter('fastest');
     if (fastest.length === 2) {
diff --git a/perf/suites.js b/perf/suites.js
index 9a36db5..28b5a32 100644
--- a/perf/suites.js
+++ b/perf/suites.js
@@ -204,6 +204,30 @@ module.exports = [
     fn: function (async, done) {
       setTimeout(done, 0);
     }
+  },
+  {
+    name: "ensureAsync sync",
+    fn: function (async, done) {
+      async.ensureAsync(function (cb) {
+        cb();
+      })(done);
+    }
+  },
+  {
+    name: "ensureAsync async",
+    fn: function (async, done) {
+      async.ensureAsync(function (cb) {
+        setImmediate(cb);
+      })(done);
+    }
+  },
+  {
+    name: "ensureAsync async noWrap",
+    fn: function (async, done) {
+      (function (cb) {
+        setImmediate(cb);
+      }(done));
+    }
   }
 ];