diff options
Diffstat (limited to 'node_modules/async/reflect.js')
-rw-r--r-- | node_modules/async/reflect.js | 28 |
1 files changed, 12 insertions, 16 deletions
diff --git a/node_modules/async/reflect.js b/node_modules/async/reflect.js index f8ab6358f..098ba8650 100644 --- a/node_modules/async/reflect.js +++ b/node_modules/async/reflect.js @@ -9,9 +9,9 @@ var _initialParams = require('./internal/initialParams'); var _initialParams2 = _interopRequireDefault(_initialParams); -var _rest = require('./internal/rest'); +var _slice = require('./internal/slice'); -var _rest2 = _interopRequireDefault(_rest); +var _slice2 = _interopRequireDefault(_slice); var _wrapAsync = require('./internal/wrapAsync'); @@ -61,23 +61,19 @@ function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { de function reflect(fn) { var _fn = (0, _wrapAsync2.default)(fn); return (0, _initialParams2.default)(function reflectOn(args, reflectCallback) { - args.push((0, _rest2.default)(function callback(err, cbArgs) { - if (err) { - reflectCallback(null, { - error: err - }); + args.push(function callback(error, cbArg) { + if (error) { + reflectCallback(null, { error: error }); } else { - var value = null; - if (cbArgs.length === 1) { - value = cbArgs[0]; - } else if (cbArgs.length > 1) { - value = cbArgs; + var value; + if (arguments.length <= 2) { + value = cbArg; + } else { + value = (0, _slice2.default)(arguments, 1); } - reflectCallback(null, { - value: value - }); + reflectCallback(null, { value: value }); } - })); + }); return _fn.apply(this, args); }); |