async：每个函数永远不会完成

Question

我正在尝试使用async library 处理二维数组并处理每个展平项目。像这样：

import { each } from 'async';

let results: any[] = [];

await each(chats, async (chat) =>
    await each(chat.participants, async (participant) => {

        console.log('Before pause');
        // do something with participant
        results.push(fn(participant));
        await this.timeout(2500);
        console.log('After pause');

      })
);

console.log('Finished');

return results;

在哪里

let chats = [
  {
    participants: ['1', '2']
  },
  {
    participants: ['3', '4']
  }
]

timeout(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}

但是，console.log('Finished') 永远不会执行。我在这段代码中尝试了很多async 和await 的变体，但无法使其正常工作。我有一个使用纯异步/等待的工作版本，但想使用异步库。

我做错了什么？

请注意，我确实在不使用异步库的情况下使用 async/await 进行了这项工作，如下所示：

await Promise.all(chats.map(
  async (chat) =>
    await Promise.all(chat.participants
      .map(async (participant) => {

        console.log('Before pause');
        // do something with participant
        results.push(fn(participant));
        await this.timeout(2500);
        console.log('After pause');

      })
    )
));

return results;

但我想使用异步库，因为我希望使用该库中的其他函数。

Answer 1

each() 的第二个参数采用以下形式：function(item, callback) {}，每次迭代完成时都需要调用callback。请注意，这与 callback 与 each() 的可选第三个参数不同。

解决方案是每次迭代调用回调，如下所示：

await each(chats, async (chat, done1 /*1️⃣*/) => {

  await each(chat.participants, async (participant, done2 /*2️⃣*/) => {
    //...
    done2(); /*3️⃣*/
  });

  done1(); /*4️⃣*/
});

console.log("Finished");

demo

Answer 2

试试这个

let chats = [
  {
    participants: ['1', '2']
  },
  {
    participants: ['3', '4']
  }
]


chats.forEach(chat =>
     chat.participants.forEach(async (participant) => {

        console.log('Before pause');
        // do something with participant
        await timeout(2500);
        console.log('After pause');
        console.log(participant)

      }));

function timeout(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}
console.log('Finished');

问题：-

• await 仅适用于异步函数
• 代替 this.timeout，在某些上下文中使用或直接在您的情况下使用。在 js here & here 中了解有关此行为的更多信息