apr-engine-run
Advanced tools
Comparing version 1.0.1 to 1.0.2
29
index.js
@@ -10,16 +10,13 @@ const Iterator = require('apr-engine-iterator'); | ||
const after = (items, end) => { | ||
return (v) => { | ||
brk = brk || items.some((item, y) => { | ||
return opts.after && opts.after(v[y], item, i++); | ||
}); | ||
const after = (items, end) => v => { | ||
brk = | ||
brk || items.some((item, y) => opts.after && opts.after(v[y], item, i++)); | ||
done = done || brk; | ||
done = done || brk; | ||
return done ? end() : next(end); | ||
}; | ||
return done ? end() : next(end); | ||
}; | ||
const next = (end) => { | ||
const items = ittr.next(opts.limit).filter((item) => { | ||
const next = end => { | ||
const items = ittr.next(opts.limit).filter(item => { | ||
done = done || item.done; | ||
@@ -29,5 +26,3 @@ return !item.done; | ||
const call = opts.call || ((item) => { | ||
return fn(item.value, item.key, input); | ||
}); | ||
const call = opts.call || (item => fn(item.value, item.key, input)); | ||
@@ -37,7 +32,5 @@ Promise.all(items.map(call)).then(after(items, end), end); | ||
return new Promise((resolve, reject) => { | ||
next((err, res) => { | ||
return err ? reject(err) : resolve(res); | ||
}); | ||
}); | ||
return new Promise((resolve, reject) => | ||
next((err, res) => (err ? reject(err) : resolve(res))) | ||
); | ||
}; |
{ | ||
"name": "apr-engine-run", | ||
"version": "1.0.1", | ||
"version": "1.0.2", | ||
"homepage": "https://github.com/ramitos/apr/tree/master/packages/engine-run", | ||
@@ -11,4 +11,4 @@ "license": "MIT", | ||
"dependencies": { | ||
"apr-engine-iterator": "^1.0.1" | ||
"apr-engine-iterator": "^1.0.2" | ||
} | ||
} |
1142
24
Updatedapr-engine-iterator@^1.0.2