节点 js - 将数据写入可写流

Question

在我的节点应用程序中，im使用createWriteStream方法中的写入方法将数据写入文件。现在我需要找到特定流的写入是否完成。我怎么能找到它。

var stream = fs.createWriteStream('myFile.txt', {flags: 'a'});
var result = stream.write(data);
writeToStream();
function writeToStream() {
  var result = stream.write(data + 'n');
  if (!result) {
    stream.once('drain',writeToStream());
  }
}

每次写入完成时，我都需要调用其他方法。我该怎么做。

Answer 1

从节点.js WritableStream.write(...)文档中，您可以为 "write" 方法提供一个在刷新写入数据时调用的回调：

var stream = fs.createWriteStream('myFile.txt', {flags: 'a'});
var data = "Hello, World!n";
stream.write(data, function() {
  // Now the data has been written.
});

请注意，在排队下一个调用之前，您可能不需要实际等待每个调用"写入"完成。 即使"write"方法返回false，您仍然可以调用后续写入，节点会将挂起的写入请求缓冲到内存中。

Answer 2

我正在使用maerics的答案以及错误处理。标志'a'用于打开文件进行追加。如果文件不存在，则创建该文件。您可以使用其他标志。

// Create a writable stream &  Write the data to stream with encoding to be utf8
    var writerStream = fs.createWriteStream('MockData/output.txt',{flags: 'a'})
                         .on('finish', function() {
                              console.log("Write Finish.");
                          })
                         .on('error', function(err){
                             console.log(err.stack);
                          });

    writerStream.write(outPutData,function() {
      // Now the data has been written.
        console.log("Write completed.");
    });
    // Mark the end of file
    writerStream.end();