summaryrefslogtreecommitdiff
path: root/lib/forever.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/forever.js')
-rw-r--r--lib/forever.js3
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/forever.js b/lib/forever.js
index 0147395..d1f3256 100644
--- a/lib/forever.js
+++ b/lib/forever.js
@@ -2,6 +2,7 @@ import noop from 'lodash/noop';
import onlyOnce from './internal/onlyOnce';
import ensureAsync from './ensureAsync';
+import wrapAsync from './internal/wrapAsync';
/**
* Calls the asynchronous function `fn` with a callback parameter that allows it
@@ -34,7 +35,7 @@ import ensureAsync from './ensureAsync';
*/
export default function forever(fn, errback) {
var done = onlyOnce(errback || noop);
- var task = ensureAsync(fn);
+ var task = ensureAsync(wrapAsync(fn));
function next(err) {
if (err) return done(err);