Как последовательно вызвать асинхронные функции и записать результат в массив?

Question

[Mulch]

Нужно с помощью async/await написать функцию которая принимает массив асинхронных функций и последовательно(следующая начинается, когда закончилась предыдущая) вызывает их, передавая в аргументы результат вызова предыдущей функции.

Пример:

const first = () =>
  new Promise((resolve) => setTimeout(() => resolve(300)), 300);

const second= () =>
  new Promise((resolve) => setTimeout(() => resolve(200)), 200);

const third = () =>
  new Promise((resolve) => setTimeout(() => resolve(100)), 100);

promises([first, second, third]);
// Выполнит resolve(300) через 300 мс, потом resolve(200) через 200 мс, потом resolve(100) через 100 мс
// [300, 200, 100]

Куда копать?

Comments

[d-sem]

куда то в эту сторону Есть ли последовательный Promise.all?

[Andrew]

.then?

Answer 1

[0xD34F]

async function chain(arr) {
  const result = [];

  for (const item of arr) {
    result.push(await item(result[result.length - 1]));
  }

  return result;
}

Или

function chain(arr) {
  const result = [];

  return arr
    .reduce((prev, curr) => prev.then(curr).then(r => (result.push(r), r)), Promise.resolve())
    .then(() => result);
}

Comments

[Mulch]

Благодарю, сконялся к этому решение но не додумал прописать length - 1 . Но один тест c этим решением почему то указывает вот что:

● promisesInSeries › должна вызывать функции в правильной последовательности

    expect(received).toStrictEqual(expected) // deep equality

    - Expected
    + Received

      Array [
    +   Array [
    +     5,
    +   ],
    +   Array [
    +     5,
    +     7,
    +   ],
    +   Array [
    +     5,
    +     7,
    +     9,
    +   ],
    +   Array [
          5,
          7,
          9,
          12,
    +   ],
    +   Array [
    +     5,
    +     7,
    +     9,
    +     12,
          3,
    +   ],
    +   Array [
    +     5,
    +     7,
    +     9,
    +     12,
    +     3,
          4,
    +   ],
      ]

      37 |     ]);
      38 |     expect(result).toBeInstanceOf(Promise);
    > 39 |     expect(await result).toStrictEqual([5, 7, 9, 12, 3, 4]);
         |                          ^
      40 |     expect(log).toStrictEqual([5, 7, 9, 12, 3, 4]);
      41 |     expect(logParams).toStrictEqual([
      42 |       [],

      at Object.toStrictEqual test.js:39:26)

[0xD34F]

Mulch, предлагаете мне угадать, что это всё значит? Нет, так не будет.

[Mulch]

0xD34F, Ок. Додумаю) Благодарю за ответ.

Answer 2

[Дима Паутов]

Promise.all

Comments

[Mulch]

Он вернет массив функций, а не массив вызовов.

[Дима Паутов]

Mulch, так а что мешает потом пройтись по массиву и вызвать все функции в нём?

[Mulch]

async function processArray(array) {
  const promises = await Promise.all(array);
  return promises.map(async (elem) => {
    return elem();
  })
}

processArray([firstPromise, secondPromise, thirdPromise]).then(data => console.log(data))

получаю массив промисов [Promise, Promise, Promise]

[Алексей Ярков]

Mulch, а зачем async внутри map?

[Mulch]

Алексей Ярков, Не много затупил. Написал следующим образом

async function processArray(array) {
  const promises = await Promise.all(
    array.map((elem) => {
      return elem()
    })
  );
  return promises
}

Но теперь они выводятся не последовательно.