javascript асинхронный цикл forEach

Question

Я пытаюсь запуститьasticsearch для массива значений (индексов), и я столкнулся с проблемой асинхронности javaScript:

function(indices) {
  let results = [];

  indices.forEach(d => ESClient.search({
      index: d.indexName,
      body: {
        query: {
          match: {
            first_name: 'fred'
          }
        }
      }
    })
    .then(resp => results.push(resp))
  )
}

В индексах должно быть три элемента, как мне возвращать результаты со всеми тремя ответами из моего поиска?

Answer 1

Выезд Promise.all

search(indices) {
  return Promise.all(
    indices.map((d) => {
      return ESClient.search(yourElasticSearchPayload)
    })
  );
}

--------------------------------------------------------------------------

this.search(indices).then((results) => {
  // do something with results
}).catch((reason) => { 
  // failure-reason of the first failed request
  console.log(reason);
});

Answer 2

В вашем случае вы можете использовать map и Promise.all. Если на карте создается массив Обещаний для этих индексов, Promise.all ждет, пока эти Обещания будут разрешены, и возвращает массив с их разрешенными значениями.

function(indices) {
  let results = Promise.all(indices.map(d => ESClient.search({
    index: d.indexName,
    body: {
      query: {
        match: {
          first_name: 'fred'
        }
      }
    }
  })))
}

Но это не так читабельно, поэтому я бы переместил обратный вызов отображения в собственную функцию:

function searchForIndex(d) {
  return ESClient.search({
    index: d.indexName,
    body: {
      query: {
        match: {
          first_name: 'fred'
        }
      }
    }
  })
}

function(indices) {
  let results = Promise.all(indices.map(searchForIndex))
}