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

$3

//导入
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;
};
};