等待事件（再次）的同步功能

Question

拼命尝试编写https://www.npmjs.com/package/node-firebird#reading-blobs-aasynchronous的同步版本

基本上我需要（a）等两次：

1. 执行回调函数，以便事件发射器可用
2. 为结束事件发生

然后返回Buffer。

我的代码（现在是JS/TS混合代码）当前执行2，但不是1：readBlob返回未定义的，然后Buffer.concat（buffers）稍后被调用…：

function readBLOB(callback: any): Buffer {
    return  callback(async (err, _, eventEmitter) => {
        let buffers = []
        if (err)
            throw err

        eventEmitter.on('data', chunk => {
            buffers.push(chunk);
        });
        return await eventEmitter.once('end', function (e) {
            return Buffer.concat(buffers)
        })
    })
}

很抱歉再问一次（是的，我检查了很多其他问题，尝试了很多东西…），但是如何使这项工作（简单…）有效？

（调用回调的函数fetch_blob_asynchttps://github.com/hgourvest/node-firebird/blob/master/lib/index.js#L4261，以防万一...）

Answer 1

这里很少有错误，比如返回回调函数，女巫返回，我猜，un定义或者在回调函数中返回一些没有意义的东西。

而且async/await在这里没有意义，它没有效果async/await仅在希望等待某个promise解决时才有用。但是你的代码中根本没有promise。

您需要的是新的promise

function readBLOB(callback) {
  return new Promise((resolve, reject) => {
    callback((err, _, eventEmitter) => {
      let buffers = [];
      if (err) reject(err);
      eventEmitter.on("data", chunk => {
        buffers.push(chunk);
      });
      eventEmitter.once("end", function(e) {
        resolve(Buffer.concat(buffers));
      });
    });
  });
}

就这么简单。如果发生错误，您可以解析缓冲区并拒绝

现在你可以像这样使用它：

readBLOB(cb).then(data => {
   console.log(data);
})