diff options
Diffstat (limited to 'lib/retryable.js')
| -rw-r--r-- | lib/retryable.js | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/lib/retryable.js b/lib/retryable.js index a541977..6fba8e2 100644 --- a/lib/retryable.js +++ b/lib/retryable.js @@ -1,5 +1,6 @@ import retry from './retry'; import initialParams from './internal/initialParams'; +import wrapAsync from './internal/wrapAsync'; /** * A close relative of [`retry`]{@link module:ControlFlow.retry}. This method wraps a task and makes it @@ -30,9 +31,10 @@ export default function (opts, task) { task = opts; opts = null; } + var _task = wrapAsync(task); return initialParams(function (args, callback) { function taskFn(cb) { - task.apply(null, args.concat(cb)); + _task.apply(null, args.concat(cb)); } if (opts) retry(opts, taskFn, callback); |