异步/等待承诺逻辑问题

Question

我正在学习如何将 async/await 与 Promise 结合使用。我对第一个承诺有一些问题。具体来说：var pres = mvc.Components.get("search1");pres.data('results', {  count: 0,  output_mode: 'json_rows'}).on("data", function(results) {  alldata3 = results._data;  console.log(alldata3)});    我正在从另一个脚本中的函数中提取结果。'search1' 的结果非常大。例如，它需要更长的时间然后搜索两个。我遇到的问题是，它不会等到“results._data”完全分配给 alldata3 后才转到 itVolTwo()。这最终给我一个异步错误，指示“alldata3.rows”未定义。无论如何要重新设计它，以便它等到它从search1接收到完整结果？这里最好的做法是什么？谢谢你的帮助！

Answer 1

您应该“承诺”事件发射器对象（something.data.on），然后您可以等待结果：

  const itVolOne = async () => {

    if (boolpool) {

        const pres = mvc.Components.get("search1");

        const alldata3 = await new Promise(resolve => {

             pres.data('results', {count: 0, output_mode: 'json_rows'}).on("data",

               results => {

                   resolve(results._data);

               }

             );

        });

        console.log(JSON.stringify(alldata3));

        const rdbms1 = mvc.Components.get("search2");

        const alldata32 = await new Promise(resolve => {

           rdbms1.data('results', {count: 0, output_mode: 'json_rows'}).on("data",

             results => {

                resolve(results._data);

             }

           );

        });

        console.log(JSON.stringify(alldata32));

        return { alldata3, alldata32 }

    } else {

       throw new Error('Unable to get the datas');

    }

  }

因此，现在 itVolOne 函数以“同步方式”返回所有结果，其余函数可以重写：

  const itVolTwo =  alldata3 => {

      return alldata3.rows.reduce((rdbmsData, row) => {

          rdbmsData[row[0]] = {

            "crit": row[1],

            "high": row[2],

            "med":  row[3], 

            "low":  row[4]

          };

          return rdbmsData;

      }, {});

  }

  const itVolThree = alldata32 => {

     return alldata32.rows.reduce((presData, row) => {

          presData[row[0]] = {

             "crit": row[1],

             "high": row[2],

             "med":  row[3], 

             "low":  row[4]

          };

          return presData;

     }, {});

  }

  const itVolFour = (rdbmsData, presData) => {

     function sum(a, b) {

        Object.keys(b).forEach(k => {

            if (b[k] && typeof b[k] === 'object') return sum(a[k] = a[k] || {}, b[k]);

            a[k] = (+a[k] || 0) + +b[k];

        });

        return a;

      }

      return [rdbmsData, presData].reduce(sum);

  }

现在您只能在第一步中等待：

  async function itInit() {

    try {

        console.log('I got to the call YEY!');

        const { alldata3, alldata32 } = await itVolOne();

        const stepTwo = itVolTwo(alldata3);

        const stepThree = itVolThree(alldata32);

        const endData = itVolFour(stepTwo, stepThree);

        console.log(JSON.stringify(endData));

        console.log('Done');

    }

    catch (error) {

        console.log('u done f\'ed up');

    }

  }

并调用主函数：

itInit();

就这样。