如何等到在nodejs中执行流异步[重复]

Question

您好，我有异步 nodejs 功能，我正在使用流概念。我想一旦流完成然后我想从这个函数返回。

const removeMapping = async function (query) {

    let stream = query.foreach();
    stream.on('data', function (record) {
       client.delete(record);
    })
    stream.on('error', function (error) {

    })
    stream.on('end', function () {
        console.log("completed");
    })
};

我是这样调用这个函数的，但是在执行这一行之后，在这之后流异步代码。

await mapping.deleteMapping(cookie);

有人知道怎么处理吗？

Answer 1

你的函数不需要是异步的，因为你没有在函数中调用 await。

你可以做的是返回一个新的承诺：

const removeMapping = function (query) {

    return new Promise((resolve, reject) => {

        let stream = query.foreach();
        stream.on('data', function (record) {
            client.delete(record);
        })
        stream.on('error', function (error) {
            reject(error);
        })
        stream.on('end', function () {
           resolve("completed");
        })

    })

};

然后，您可以根据流中返回的内容解决或拒绝。