javascript - Node JS async/await 与多个 fs.writeFile 使用 through2 (Gulp/Vinyl)
问题描述
我正在使用through2从 Gulp 流中生成多个文件。我正在使用 NodeJS 10.6.0,所以我想我会充分利用 async/await,但我还没有完全理解其中的机制。目前 through2done()
回调在所有文件被写入之前被触发。
这是我所拥有的(简化的) - 请注意,我没有在最后返回流,因为没有必要。
async function createDirectory(pathDir) {
return new Promise((resolve, reject) => {
mkdirp(pathDir, (err) => {
if (err) reject(err);
else resolve();
});
});
}
async function writeFile(outputFilePath, outputFileContent) {
return new Promise((resolve, reject) => {
fs.writeFile(outputFilePath, outputFileContent, (err) => {
if (err) reject(err);
else resolve();
});
});
}
async function doWriteFile(outputFolderPath, outputFilePath, outputContent) {
await createDirectory(outputFolderPath);
await writeFile(outputFilePath, outputContent, outputContent);
}
async function doGenerateVariant(data, variantArr) {
for (const variant of variantArr) {
/* Do a load of stuff */
const variantOutputFolderPath = blah;
const variantOutputFilePath = blah;
const variantOutputContent = blah;
await doWriteFile(variantOutputFolderPath, variantOutputFilePath, variantOutputContent);
}
}
const generateVariant = () => {
return through.obj((file, enc, done) => {
const data = JSON.parse(file.contents.toString());
*/ Do a load of stuff */
const { variant } = data;
const variantArr = Object.values(variant);
doGenerateVariant(data, variantArr);
return done();
});
};
这不起作用,因为done()
在写入所有文件之前返回。我猜我错过了一两个回报,但我所做的一切似乎都没有奏效。
如果我在一切按预期工作后done()
进入doGenerateVariant
并调用它,doWriteFile
但我知道这是不正确的。
解决方案
doGenerateVariant
在调用之前,您需要等待完成它的工作done
。记住async
函数总是返回一个 Promise。所以你可以这样做
const generateVariant = () => {
return through.obj((file, enc, done) => {
const data = JSON.parse(file.contents.toString());
*/ Do a load of stuff */
const { variant } = data;
const variantArr = Object.values(variant);
doGenerateVariant(data, variantArr).then(() => done());
});
};
或使用async/await
const generateVariant = () => {
return through.obj(async (file, enc, done) => {
const data = JSON.parse(file.contents.toString());
*/ Do a load of stuff */
const { variant } = data;
const variantArr = Object.values(variant);
await doGenerateVariant(data, variantArr);
done();
});
};
推荐阅读
- css - LESS CSS 条件不评估 iscolor
- apache-spark - 使用 pyspark 中的 groupBy 函数使用 QuantileDiscretizer 进行分桶
- c++ - “未定义引用”Ros Cpp 库问题
- python - 使用 Django 和数据库代码的连接中止错误
- python - 使用 Fastai 的并行函数进行 pandas 聚合
- python - 为 3 维向量创建一个类
- python - 循环遍历一个txt文件
- sql-server - 在查询期间动态调整事务隔离级别
- vue.js - NuxtJS 道具:为什么这个道具显示为未定义?
- django - 如何在 DJango 中处理耗时的任务?