尝试写入新文件之前，无法完成文件的读取和处理与承诺有关的

问题描述

真的挣扎在这里和刚刚失去了在这一点上。除非我尝试使用SEEM，否则它很简单。我提供的简化代码不包含使事情简单的承诺。在放弃几个月后，我又回到了这一点。这个小脚本逐行读取目录中的文件，并将所有这些行添加到数组中。一旦结束，我想将所有这些文件写入新文件。
当然，问题是在allTheLines数组中充满了从目录文件读取的行之前，将调用writeallLinesToFile。该数组完全为空，读取文件中的任何内容均未写入新文件中。 我对此进行了很多尝试，并且在这种尝试中弄乱了我的真实代码。有人可以把我推过来吗？

var allTheLines = [];

function processFile(inputFile) {
    var fs = require('fs');
    var readline = require('readline');
    var instream = fs.createReadStream(inputFile);
    var outstream = new (require('stream'))();
    var rl = readline.createInterface(instream,outstream);

    // when you get a line,do this 
    rl.on('line',function (line) {
        // console.log("pushing: ",line);
        allTheLines.push(line);
    });

    // when there are no more lines do this
    rl.on('close',function (line) {
        console.log('...end of a file');
    });
}

function writeallLinesToFile() {
    var fs = require('fs');
    for (var i = 0; i < allTheLines.length; i++) {
        console.log("line: : ",allTheLines[i]);
        fs.appendFile('./allTheLines.html',allTheLines[i] + '\n',function (err) {
            if (err) throw err;
        });
    };
    console.log("Done writing.");
}

// ***************************************
// Execution Starts Here
// ***************************************
var fs = require('fs');
fs.readdir('./filesToRead',(err,files) => {
    for (var i = 0; i < files.length; i++) {
        processFile('./filesToRead/' + files[i]);
        console.log('file#: ',i);
    };
    console.log('Done processing files.');
    writeallLinesToFile();
});

解决方法

这是我对此的快速解决方案，您可以从这里获取并对其进行改进，以使其适合您的需求。

我相信您忘记的最重要的事情是，当我们使用事件发射器时，我们应该知道它们是异步代码而不是同步的，这就是为什么 writeAllLinesToFile 具有空数组的原因，因为它以前被调用过 rl.on（'line'，....）已经完成了工作，要赶上它很棘手;）

希望这将帮助您了解Promises的工作原理，并始终仔细考虑异步代码。

var fs = require('fs');
var readline = require('readline');
var path = require('path');
var stream = require('stream');

function processFile(inputFile) {
    var instream = fs.createReadStream(inputFile);
    var outstream = new stream();
    var rl = readline.createInterface(instream,outstream);
    var allTheLines = [];

    // when you get a line,do this 
    rl.on('line',function (line) {
        allTheLines.push(line);
    }).on('close',function () {
        writeAllLinesToFile(allTheLines);
    });
}

function writeAllLinesToFile(lines) {
    for (var i = 0; i < lines.length; i++) {
        fs.appendFile(path.join(__dirname,'allTheLines.html'),lines[i] + '\n',function (err) {
            if (err) throw err;
        });
    };
  
    console.log("Done writing.");
}

// ***************************************
// Execution Starts Here
// ***************************************

fs.readdir(path.join(__dirname,'filesToRead'),(err,files) => {
  if (err) throw err;

    for (var i = 0; i < files.length; i++) {
        processFile(path.join(__dirname,'filesToRead',files[i]));
    };

    console.log('Done processing files.');
});