diff options
author | Alex Early <alexander.early@gmail.com> | 2019-05-19 17:17:29 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-05-19 17:17:29 -0700 |
commit | 667e71760e7f2dd558e868796bd6e6008a3bac16 (patch) | |
tree | dc700c791438f49eea5e2d2aff2737e7a5442f0f /lib/internal/applyEach.js | |
parent | 4330d536c106592139fa82062494c9dba0da1fdb (diff) | |
download | async-667e71760e7f2dd558e868796bd6e6008a3bac16.tar.gz |
BREAKING CHANGE: remove partial application feature of applyEach (#1640)
* BREAKING CHANGE: remove partial application feature of applyEach
* add awaitable tests for applyEach
Diffstat (limited to 'lib/internal/applyEach.js')
-rw-r--r-- | lib/internal/applyEach.js | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/lib/internal/applyEach.js b/lib/internal/applyEach.js index f95d8ac..c08a5eb 100644 --- a/lib/internal/applyEach.js +++ b/lib/internal/applyEach.js @@ -1,17 +1,14 @@ -import initialParams from './initialParams'; import wrapAsync from './wrapAsync'; +import awaitify from './awaitify' -export default function applyEach(eachfn) { - return function(fns, ...callArgs) { - var go = initialParams(function(args, callback) { +export default function (eachfn) { + return function applyEach(fns, ...callArgs) { + const go = awaitify(function (callback) { var that = this; return eachfn(fns, (fn, cb) => { - wrapAsync(fn).apply(that, args.concat(cb)); + wrapAsync(fn).apply(that, callArgs.concat(cb)); }, callback); }); - if (callArgs.length) { - return go.apply(this, callArgs); - } return go; }; } |