如何在文件流完成写入之前等待我关闭它？

Question

我创建一个文件流来写一个 csv 文件：

    var logger = fs.createWriteStream('restaurants.csv', {
      flags: 'w' // 'a' means appending (old data will be preserved)
    });
    logger.write("sep=,\n");

写完后，我会这样关闭流：

    logger.end();
    logger.close();

但是当我这样做时，文件的一部分最后会丢失。我试着在关闭流之前睡觉：

    await Promise.delay(2000);
    logger.end();
    logger.close();

突然间，文件完成了。但是超时是一种愚蠢的解决方案。文件流在完成写入后是否发出任何事件。基本上我需要的是：

    await logger.doneWriting();
    logger.end();
    logger.close();

我当然可以承诺任何事件，但它是哪个事件？

Answer 1

fs.createWriteStream() 返回一个WriteStream 对象，它是一个WritableStream，这意味着当您调用.write() 时，您正在调用writable.write()，它实际上将回调作为参数，因此您可以正确关闭流完成后！

var logger = fs.createWriteStream('restaurants.csv', {
  flags: 'w' // 'a' means appending (old data will be preserved)
});
logger.write("sep=,\n", () => {
    // Done writing... do what's needed then close the stream if it isn't used anymore
});

如今，异步 JavaScript 实际上已成为一种标准，请始终注意回调函数，它允许您在异步块完成后运行代码。