aboutsummaryrefslogtreecommitdiff
path: root/node_modules/async/reflect.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/async/reflect.js')
-rw-r--r--node_modules/async/reflect.js28
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);
});