使用 Promises 递归修改对象

Question

我正在尝试遍历 ElasticSearch 的结果并通过替换数组中的项目来修改原始对象。我快完成了，但是 Promise 被解决了不止一次，让我没有可用的结果。

我正在使用source.included = Array.map() 将原始数组替换为函数调用的结果，它几乎可以正常工作。保持对象的原始结构和included 数组中的顺序很重要，这就是我决定尝试这种方法的原因。我试图将自己定位在this example，但 Promise.all() 不知何故无法解决这些承诺。有什么想法吗？

let source = {
  title: '1',
  included: [{
    _id: 'new',
    _type: 'mytype'
  }]
}

function recursiveGet (source) {
  return new Promise((resolve, reject) => {
    client.mget({
      body: {
        docs: docsToFetch
      }
    })
    .then(response => {
      return source.included.map(item => {
        return somethingAsync(response)
      })
    })
    .then(promises => {
      Promise.all(promises)
        .then(resolved => {
          source.included = resolved.map(doc => {
            if (doc.included && !doc.resolved) {
              resolve(recursiveGet(doc))
            } else {
              resolve(doc)
            }
          })
        })
    })
  })
}

recursiveGet(source)

Answer 1

避免Promise constructor antipattern！

您不能（绝不能）多次调用resolve - 在您的情况下，从map 循环中。改用这个：

function recursiveGet (source) {
  return client.mget({
    body: {
      docs: docsToFetch
    }
  }).then(response => {
    let promises = source.included.map(item => {
      return somethingAsync(response) // did you mean `item` here?
    })
    return Promise.all(promises);
  })
  .then(resolved => {
    let morePromises = resolved.map(doc => {
//                              ^^^ another loop...
      if (doc.included && !doc.resolved) {
        return recursiveGet(doc);
      } else {
        return doc;
      }
    });
    return Promise.all(morePromises).then(moreResults => {
//         ^^^^^^^^^^^ another Promise.all!
      source.included = moreResults;
      return source;
    });
  });
}

如果您不想要两个顺序循环，您还可以将每个结果处理回调直接链接到 somethingAsync 承诺。