diff --git a/lib/services/cursor/eachAsync.js b/lib/services/cursor/eachAsync.js index 1f28db6c812..251fe9c8252 100644 --- a/lib/services/cursor/eachAsync.js +++ b/lib/services/cursor/eachAsync.js @@ -30,7 +30,7 @@ module.exports = function eachAsync(next, fn, options, callback) { if (promise && typeof promise.then === 'function') { promise.then( function() { callback(null); }, - function(error) { callback(error); }); + function(error) { callback(error || new Error('`eachAsync()` promise rejected without error')); }); } else { callback(null); }