diff options
Diffstat (limited to 'lib/ensureAsync.js')
-rw-r--r-- | lib/ensureAsync.js | 2 |
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 () { |