🌵4. map/filter/reject
在async中，each系列的方法一共有12个：
each/forEacheachOf/forEachOfeachLimit/forEachLimiteachOfLimit/forEachOfLimiteachSeries/forEachSerieseachOfSeries/forEachOfSeries
这些方法的回调函数签名为callback(err)，只有一个参数表示是否出错，因此无法收集到每个异步任务的结果。如果我们希望如下调用：
javascript
map(files, fs.readFile, function(err, result) {
if (err) {
throw err;
}
result.forEach(data => console.log(data.toString()));
});考虑到对于数组而言，可以通过forEach来实现map功能，例如：
javascript
function arrayMap(arr, fn) {
var result = [];
arr.forEach((val, key) => result.push(fn(val, key, arr)));
return result;
}因此，在这里，可以通过async.eachOf来实现map，代码逻辑如下：
javascript
function map(arr, fn, callback) {
calback = once(callback || function() {});
arr = arr || [];
var result = Array.isArray(arr) ? [] : {};
async.eachOf(arr, function(val, key, callback) {
fn(val, function(err, data) {
result[key] = data;
callback(err);
});
}, function(err) {
callback(err, result);
});
}同样，mapLimit和mapSeries也可以通过类似的方式实现。
filter功能的实现也是类似的方式，例如我们希望过滤出所有存在的文件，期望的调用方式如下：
javascript
// 由于fs.exists已经废弃，否则可以直接filter(files, fs.exists, callback)
filter(files, function(file, callback) {
fs.access(file, function(err) {
callback(err ? false : true);
});
}, function(err, result) {
if (err) {
throw err;
}
console.log(result);
});filter的实现如下：
javascript
function filter(arr, fn, callback) {
calback = once(callback || function() {});
arr = arr || [];
var result = [];
async.eachOf(arr, function(val, key, callback) {
fn(val, function(v) {
if (v) {
result.push(val);
}
callback();
});
}, function(err) {
callback(err, result);
});
}同样，filterLimit和filterSeries也可以通过类似的方式实现。
而reject的实现与filter几乎一样，除了判断条件不同之外，在async中的源码如下：
javascript
function _reject(eachfn, arr, iterator, callback) {
_filter(eachfn, arr, function(value, cb) {
iterator(value, function(v) {
cb(!v);
});
}, callback);
}
async.reject = doParallel(_reject);
async.rejectLimit = doParallelLimit(_reject)5. some/every/detect
some实现逻辑如下：
javascript
function some(arr, fn, cb) {
async.eachOf(arr, function(val, key, callback) {
// 如果cb为null，说明之前已经有某个任务的结果为truthy
// 因此直接执行callback，相当于跳过该任务
if (!cb) {
return callback();
}
fn(val, function(v) {
// 如果该任务返回truthy，则调用最终的回调cb(true)
// 然后将cb置为null，表示已经有了truthy值，从而阻止后续任务的继续执行
if (cb && !!v) {
cb(true);
cb = null;
}
callback();
});
}, function(err) {
// 此时所有任务已经执行完毕，如果cb仍然不为null
// 说明所有的任务都返回了falsy，因此最终为cb(false)
if (cb) {
cb(false);
}
});
}
// example
some(files, function(file, callback) {
fs.access(file, function(err) {
callback(err ? false : true);
});
}, function(val) {
console.log(val);
});every与此类似，实现逻辑如下：
javascript
function every(arr, fn, cb) {
async.eachOf(arr, function(val, key, callback) {
// 如果cb为null，说明之前已经有某个任务的结果为falsy
// 因此直接执行callback，相当于跳过该任务
if (!cb) {
return callback();
}
fn(val, function(v) {
// 如果该任务返回falsy，则调用最终的回调cb(false)
// 然后将cb置为null，表示已经有了falsy值，从而阻止后续任务的继续执行
if (cb && !v) {
cb(false);
cb = null;
}
callback();
});
}, function(err) {
// 此时所有任务已经执行完毕，如果cb仍然不为null
// 说明所有的任务都返回了truthy，因此最终为cb(true)
if (cb) {
cb(true);
}
});
}
// example
every(files, function(file, callback) {
fs.access(file, function(err) {
callback(err ? false : true);
});
}, function(val) {
console.log(val);
});detect返回的是第一个执行为truthy的值，与some非常类似，只需要将cb(true)和cb(false)分别替换为cb(val)和cb(undefined)即可。
6. reduce/reduceRight
reduce和reduceRight主要通过async.eachOfSeries来实现，注意reduce相关的只有一个series版本，即只有串行执行的版本，因为涉及到reduce的操作往往是要依赖于上一次操作的返回值，因此不能够并行执行。
这部分源码比较简单，不做赘述。
7. sortBy
sortBy的思路是：
- 首先通过
async.map将数组映射为一个新的数组，新数组中得每一项结构为{value: x, criteria: criteria}x为原数组中的元素criteria为需要比较的标准
- 新的数组会作为第二个参数传给
async.map的回调函数，在该回调函数中，以criteria对新数组进行排序 - 从排好序的数组中收集所有的
value作为最终的结果集传递给sortBy的回调函数