这是一个提供了异步遍历功能的工具，可以通过

async-each

这是一个提供了异步遍历功能的工具，可以通过插件拓展工具的遍历器。已经提供的方法包括forEach，every，some，filter，map，sort，reduce。

安装： npm install async-series-each --save-dev

提供的遍历器： forEach(callback[, thisArg])

调用方法及参数和同步版本forEach(Array.prototype.forEach)一致，功能也一致。

every(callback[, thisArg])

调用方法及参数和同步版本every(Array.prototype.every)一致，功能也一致。

some(callback[, thisArg])

调用方法及参数和同步版本some(Array.prototype.some)一致，功能也一致。

filter(callback[, thisArg])

调用方法及参数和同步版本filter(Array.prototype.filter)一致，功能也一致。

map(callback[, thisArg])

调用方法及参数和同步版本map(Array.prototype.map)一致，功能也一致。

reduce(callback[, fir])

调用方法及参数和同步版本reduce(Array.prototype.reduce)一致，功能也一致。

sort(callback)

调用方法及参数和同步版本sort(Array.prototype.sort)一致，功能也一致。内部采用的是插入排序，海量数据慎用。

你可以通过插件编写需要的遍历器 用法：

建议安装promise化工具： npm install new-promiseify --save-dev

调用环境应该是在async函数内部或者Promise实例的回调函数内部

//导入 const each = require('async-series-each'); const promiseify = require('new-promiseify'); const fs = require('fs'); //forEach await each([0, 0, 0, 0]).forEach(async(cur, i, ar) => { await promiseify([setTimeout, 0, 0])(5000); console.log(`Current index is ${i}`); }); //every const vaild = await each([1, 2, 3, 0, 4]).every(async(cur, i, ar) => { await promiseify([setTimeout, 0, 0])(5000); return console.log(cur) || cur; }); //some const vaild = await each([0, 0, 0, false, true, 1]).some(async(cur, i, ar) => { await promiseify([setTimeout, 0, 0])(5000); return console.log(cur) || cur; }); //filter const ar = await each([1, 2, 0, false, true, [], {}, null]).filter(async(cur, i, ar) => { await promiseify([setTimeout, 0, 0])(5000); return console.log(cur) || !cur; }); //map const ctns = await each(['./1.md', './2.md', './3.md']).map(async(cur, i, ar) => { const ctn = await promiseify(fs.readFile)(cur, 'utf8'); return console.log(cur) || ctn; }); //reduce const res = await each(['./1.md', './2.md', './3.md']).reduce(async(res, cur, i, ar) => { const ctn = await promiseify(fs.readFile)(cur, 'utf8'); return console.log(cur) || `${res + (i + 1)}. ${ctn}\n`; }, 'Read file content:\n'); //sort const ar = await each(['./1.md', './2.md', './3.md']).sort(async(prev, cur) => { const rdFile = promiseify(fs.readFile), firCtn = await rdFile(prev, 'utf8'), secCtn = await rdFile(cur, 'utf8'); return firCtn > secCtn ? 1 : -1; }); 一点说明

为什么不直接在Array.prototype上拓展？ 因为我希望这个拓展是温和的，而不是具有侵入性的。

插件的写法

以some方法为例

module.exports = function SomeAsyncPlugin(Series) { //Regist some command to prototype of Series Series.prototype.some = async function(callback, cur = Series.root) { callback = callback.bind(cur); const src = this.source, len = src.length; for (let i = 0; i < len; i++) { const cont = await callback(src[i], i, src); if (cont) return true; } return false; }; };