node.js - 如何在 NodeJs 中对事件使用 readline(等待流关闭)

Question

我正在创建一个机器人，当它收到消息时，它开始读取文本文件并使用文件内容响应消息。

不幸的是，我无法摆脱这个异步 hell ，我只得到错误、未定义或 promise

最后一个实验是这样的:

const fs = require('fs');
const readline = require('readline');

// bot.listen("message").reply(responseText())

function readFile(file) {
    var text = '';
        var readInterface = readline.createInterface({
            input: fs.createReadStream(file),
            terminal: false
        });

        readInterface.on('line', function(line) {
            linea = line.trim();
            console.log(linea);
            text += linea;
        }).on('close', function() {
            return text;
        });
    });
}

async function responseText() {
    var content = await readFile("file.txt");
    content.then(function(data) {
        return data;
    })
}

我想要得到的是延迟响应，直到我得到文件的内容。我知道 Node 是基于异步的，但我不知道如何处理它!

谢谢大家

Answer 1

如果你想使用async-await需要创建一个promise并返回它。

function readFile(file) {
    return new Promise((res, rej) => {
        try {
            var text = '';
            var readInterface = readline.createInterface({
                input: fs.createReadStream(file),
                terminal: false
            });

            readInterface
                .on('line', function (line) {
                    linea = line.trim();
                    text += linea;
                })
                .on('close', function () {
                    res(text);
                });
        } catch(err){
            rej(err)
        }
    });
}