Обещать все повторить

Обещания стремятся конструировать и моделировать значение, полученное асинхронно, Promise создается с использованием какого-либо производителя, например fetch.

Если вы сохраните ссылку на этого производителя, вы можете воспроизвести механизм это в первую очередь произвело Обещание.

// producer function
function getData (arg) {
  const result = new Promise();
  return result.then(value => {
    return { ok:true, value };
  }, error => {
    return {
      ok: false,
      value: error,
      // retry is a function which calls the producer with the same arguments
      retry: () => getData(arg)
    };
  })

}

Тогда, если у вас есть что-то вроде:

const data = [];

// Promise<{ok: boolean, value: any, retry?: function}>
// No promises will fail in this array
const asyncResults = data.map(getResults); 


Promise.all(asyncResults)
  .then((results) => {
    const successes = results.filter(res => res.ok);
    const retrys = results.filter(res => !res.ok).map(res => res.retry()); // retry all failed promises
  })

Утечки памяти, переполнение стека: поскольку я сохраняю ссылку на исходные аргументы, чтобы повторить попытку, а алгоритм является рекурсивным, возможна утечка памяти. Однако алгоритм не может «переполнить стек»:

• Звонки getData со временем не становятся «глубже» (см. Определение retry)
• асинхронность алгоритма предотвращает такое поведение, если обещание никогда не было выполнено
• старые данные правильно отбрасываются при доступе к результатам как const resultData = results.filter(res => res.ok).map(res => res.value);

Однако алгоритм может занять много времени, если обещание не будет разрешено и будет препятствовать доступу к остальным значениям.

В качестве альтернативы я предлагаю вам взглянуть на другой асинхронный примитив, еще не являющийся частью языка (возможно, когда-нибудь): Observables, который предназначен для такого рода задач: ленивые асинхронные операции с возможностью повторения.

Вы можете использовать асинхронный пакет и заключить все вызовы обещаний закрытием с аргументом done.

Затем просто разрешите результаты.

const async = require('async');

const promiseAll = promises => {
  return new Promise((resolve) => {
    const parallelCalls = promises.map(promise => {
      return done => {
        promise
          .then(result => done(null, result)
          .catch(error => {
            console.error(error.message);
            done();
          });
      }
    });
    async.parallel(
      parallelCalls, 
      (_, results) => resolve(results.filter(result => result))
    );
  });
};


router.get('/something', async (req, res) => {
  ...
  const results = await promiseAll(promises);
  ...
});