异步:每个函数永远不会完成

我在试着用 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的工作版本,但希望使用异步库。

我做错什么了?

请注意,我确实使用了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;