summaryrefslogtreecommitdiff
path: root/lib/internal/applyEach.js
diff options
context:
space:
mode:
authorAlex Early <alexander.early@gmail.com>2019-05-19 17:17:29 -0700
committerGitHub <noreply@github.com>2019-05-19 17:17:29 -0700
commit667e71760e7f2dd558e868796bd6e6008a3bac16 (patch)
treedc700c791438f49eea5e2d2aff2737e7a5442f0f /lib/internal/applyEach.js
parent4330d536c106592139fa82062494c9dba0da1fdb (diff)
downloadasync-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.js13
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;
};
}