异步返回解析的 JSON 数组

Question

我正在尝试解析示例 JSON 并将各个对象推送到数组中。我遇到的问题是我认为它正在工作，但是当调用console.log 打印结果时，它返回一个undefined 值。我相信这是因为我没有正确处理我的 async/await 请求，但我不确定在所有元素都被推送到我的数组之前如何不运行 console.log 函数。

Attacks.js

//Assume JSON output = {attack source, attack destination, attack type}

//Required modules
//@ts-ignore: undeclared module
//const watchStream = require('fs-watch-stream')
const es = require('event-stream')
var JSONStream = require('JSONStream')
const fs = require('fs');


async function initial(){
    var arr = [];
    var stream = fs.createReadStream('sample.json', {start: 3, encoding: 'utf8'});
    var parser = JSONStream.parse('employees.employee.*');
    stream.pipe(parser);

    parser.on('data', function (obj) {
        arr.push(obj);
    });

    parser.on('finish', async function(arr) {
        return(arr) = await Promise.resolve(arr);
    });
};

initial().then(arr => console.log(arr));

sample.json

{
  "employees": {
    "employee": [
      {
        "id": "1",
        "firstName": "Tom",
        "lastName": "Cruise",
        "photo": "https://jsonformatter.org/img/tom-cruise.jpg"
      },
      {
        "id": "2",
        "firstName": "Maria",
        "lastName": "Sharapova",
        "photo": "https://jsonformatter.org/img/Maria-Sharapova.jpg"
      },
      {
        "id": "3",
        "firstName": "Robert",
        "lastName": "Downey Jr.",
        "photo": "https://jsonformatter.org/img/Robert-Downey-Jr.jpg"
      }
    ]
  }
}

Answer 1

下面的代码简单地定义了一个事件处理程序；你的 initial 函数甚至不会等待委托执行，更不用说完成了：

parser.on('finish', async function(arr) {
    return(arr) = await Promise.resolve(arr);
});

您应该将处理程序包装在Promise 中，initial 可以等待：

await Promise(resolve => parser.on("finish", resolve));

Answer 2

问题出在这部分：

parser.on('finish', async function(arr) {
  return(arr) = await Promise.resolve(arr);
});

当finish事件被触发时，回调函数function(arr)被调用，但是因为它是一个函数，所以它里面的任何return语句都不会被initial()返回，而是被function(arr)返回并且没有分配任何变量，因此return(arr) 中返回的值丢失了。您期望 initial() 解析为 arr 但由于 return arr 语句已经在 function(arr) 内部，因此返回值丢失，并且因为 initial 最终没有任何 return 语句它解析到undefined。我认为在这种情况下，更简单的方法是使用经典的承诺流程。

function initial(){
   return new Promise(resolve => {
      var arr = [];
      var stream = fs.createReadStream('sample.json', {start: 3, encoding: 'utf8'});
      var parser = JSONStream.parse('employees.employee.*');
      stream.pipe(parser);

      parser.on('data', function (obj) {
        arr.push(obj);
      });

      parser.on('finish', function(arr) {
        resolve(arr);
      });
   }) 
};

initial().then(arr => console.log(arr));