summaryrefslogtreecommitdiff
path: root/lib/ensureAsync.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/ensureAsync.js')
-rw-r--r--lib/ensureAsync.js2
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/ensureAsync.js b/lib/ensureAsync.js
index c60d07e..8582bba 100644
--- a/lib/ensureAsync.js
+++ b/lib/ensureAsync.js
@@ -1,5 +1,6 @@
import setImmediate from './internal/setImmediate';
import initialParams from './internal/initialParams';
+import { isAsync } from './internal/wrapAsync';
/**
* Wrap an async function and ensure it calls its callback on a later tick of
@@ -36,6 +37,7 @@ import initialParams from './internal/initialParams';
* async.mapSeries(args, async.ensureAsync(sometimesAsync), done);
*/
export default function ensureAsync(fn) {
+ if (isAsync(fn)) return fn;
return initialParams(function (args, callback) {
var sync = true;
args.push(function () {