1 files changed, 2 insertions, 1 deletions
diff --git a/lib/waterfall.js b/lib/waterfall.js
index 7bc60da..cb2c1fd 100644
--- a/lib/waterfall.js
+++ b/lib/waterfall.js
@@ -4,6 +4,7 @@ import once from './internal/once';
 import rest from './internal/rest';
 
 import onlyOnce from './internal/onlyOnce';
+import wrapAsync from './internal/wrapAsync';
 
 /**
  * Runs the `tasks` array of functions in series, each passing their results to
@@ -82,7 +83,7 @@ export default  function(tasks, callback) {
 
         args.push(taskCallback);
 
-        var task = tasks[taskIndex++];
+        var task = wrapAsync(tasks[taskIndex++]);
         task.apply(null, args);
     }