我正在尝试使用async.waterfall从dir中读取一些文件，在我看来我做的不错，但是我得到了指定的错误，并且从未调用过readData函数。怎么了？
var fs = require("fs");
var async = require("async");
var folder = "./files/";
try {
async.waterfall([
function readDir(cb) {
fs.readdir(folder, function(err, files) {
cb(err, files);
});
},
function loopFiles(files, cb) {
files.forEach(function(fn) {
console.log("loop " + fn);
cb(null, fn);
});
},
function check(fn, cb) {
console.log("check "+fn);
fs.stat(folder + fn, function(err, stats) {
console.log(stats.isFile());
cb(err, stats, fn);
});
},
function readData(stats, fn, cb) {
console.log("read "+fn);
if (stats.isFile()) {
fs.readFile(folder + fn, "utf-8", function(err, data) {
cb(err, data);
});
}
}
], function(err, result) {
if (err) {
throw err;
}
console.log(result);
});
} catch (err) {
console.log(err);
}
问题是，我们在调用cb(null, fn)中loopFiles()多次如果files.length > 1。您可能需要对每个文件执行单独的操作async.waterfall()或使用其他async.*方法。
另一个问题是，readData()在情况不cb()为的情况下，您没有打电话stats.isFile()给您false。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句