aboutsummaryrefslogtreecommitdiff
path: root/node_modules/slide/lib/async-map.js
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2019-03-27 21:01:33 +0100
committerFlorian Dold <florian.dold@gmail.com>2019-03-27 21:01:33 +0100
commitcc97a4dd2a967e1c2273bd5f4c5f49a5bf2e2585 (patch)
tree92c5d88706a6ffc654d1b133618d357890e7096b /node_modules/slide/lib/async-map.js
parent3771b4d6b67b34c130f3a9a1a15f42deefdb2eda (diff)
remove node_modules
Diffstat (limited to 'node_modules/slide/lib/async-map.js')
-rw-r--r--node_modules/slide/lib/async-map.js54
1 files changed, 0 insertions, 54 deletions
diff --git a/node_modules/slide/lib/async-map.js b/node_modules/slide/lib/async-map.js
deleted file mode 100644
index ccf345f3c..000000000
--- a/node_modules/slide/lib/async-map.js
+++ /dev/null
@@ -1,54 +0,0 @@
-
-/*
-usage:
-
-// do something to a list of things
-asyncMap(myListOfStuff, function (thing, cb) { doSomething(thing.foo, cb) }, cb)
-// do more than one thing to each item
-asyncMap(list, fooFn, barFn, cb)
-
-*/
-
-module.exports = asyncMap
-
-function asyncMap () {
- var steps = Array.prototype.slice.call(arguments)
- , list = steps.shift() || []
- , cb_ = steps.pop()
- if (typeof cb_ !== "function") throw new Error(
- "No callback provided to asyncMap")
- if (!list) return cb_(null, [])
- if (!Array.isArray(list)) list = [list]
- var n = steps.length
- , data = [] // 2d array
- , errState = null
- , l = list.length
- , a = l * n
- if (!a) return cb_(null, [])
- function cb (er) {
- if (er && !errState) errState = er
-
- var argLen = arguments.length
- for (var i = 1; i < argLen; i ++) if (arguments[i] !== undefined) {
- data[i - 1] = (data[i - 1] || []).concat(arguments[i])
- }
- // see if any new things have been added.
- if (list.length > l) {
- var newList = list.slice(l)
- a += (list.length - l) * n
- l = list.length
- process.nextTick(function () {
- newList.forEach(function (ar) {
- steps.forEach(function (fn) { fn(ar, cb) })
- })
- })
- }
-
- if (--a === 0) cb_.apply(null, [errState].concat(data))
- }
- // expect the supplied cb function to be called
- // "n" times for each thing in the array.
- list.forEach(function (ar) {
- steps.forEach(function (fn) { fn(ar, cb) })
- })
-}