使用包含承诺的一系列承诺

Question

我正在执行以下代码：

let promises = []
querySnapshot.forEach(function (doc) {
  promises.push(
    promiseFunction()
    .then((postCounters) => {
      promiseFunction2()
        .then((myRate) => {
        console.log('save array with postCounters AND myRate data')
      })
    })
  )
})
Promise.all(promises).then(() => {
  console.log('the array with postCounters AND myRate data')
})

事情越来越不对劲了。返回的 Promise.all 不会等到 promiseFunction2 运行，所以第二个函数不起作用，我没有在我的数组中获取 promiseFunction2 数据，只是第一个。

我认为正在发生的事情是：Promise.all 在所有 promiseFunction 运行后得到，但它不会等到第二个函数，我想在得到所有承诺之前等待两者都完成，我应该使用两个 Promise 。全部？？？

我对 Promise.all 的语法不是很熟悉，我只是使用 promiseFunction().then() 方法

（使我的代码保持一致以良好扩展的事件）

Answer 1

您应该使用map 将一个数组转换为另一个数组。问题是您没有返回从 promiseFunction2 生成的承诺链：

const promises = querySnapshot.map((doc) => (
  promiseFunction()
    .then((postCounters) => (
      promiseFunction2()
        .then((myRate) => {
        console.log('save array with postCounters AND myRate data')
      })
    ))
));
Promise.all(promises).then(() => {
  console.log('the array with postCounters AND myRate data')
});

或者，为了减少压痕噪音，使用async/await：

const promises = querySnapshot.map(async (doc) => {
  const postCounters = await promiseFunction();
  const myRate = await promiseFunction2();
  // do stuff with myRate
  console.log('save array with postCounters AND myRate data')
  // async functions automatically return promises that resolve when the block finishes
});
Promise.all(promises).then(() => {
  console.log('the array with postCounters AND myRate data')
})

Answer 2

看看这是否有帮助。

  let promises = []
  querySnapshot.forEach(function (doc) {
    promises.push(
      promiseFunction()
        .then((postCounters) => {
          return promiseFunction2();
        })
    )
  })
  Promise.all(promises).then((values) => {
    console.log(values);
  })

Answer 3

你为什么不用这样的promise？！

let promises = [],
    promiseArr = [];
querySnapshot.forEach(function (doc) {
    promises.push(
        promiseFunction()
    );
});
Promise.all(promises).then((res) => {
    res.forEach(itm => {
        promiseArr.push(
            promiseFunction2()
        );
    });


    Promise.all(promiseArr).then((res) => {
        console.log('save array with postCounters AND myRate data');
    });

});

Answer 4

这样使用

let addQueue = q();

for (let i = 0; i < querySnapshot.length; i++){
 addQueue = addQueue.then(promisFunction.bind(null, querySnapshot[i]))
                        .then(function (r) {
                            console.log('OK: ', r);
                        })
}

function promisFunction(doc){
let deferred = q.defer();

promisFunction2().then((postCounters) =>{
and function for myRate 
deferred.resolve({ a: doc, b: postCounters c: myRate }) }
})
return deferred.promise//
}


 addQueue.then(function (result) {
                    console.log('your result is here');
                })

Answer 5

在您的示例中，您没有说明为什么promiseFunction2 需要等待promiseFunction。这两个函数都没有返回一些东西，所以不清楚你声称缺少什么值。

如果promiseFunction2 需要在promiseFunction 之后运行，那么您可以这样做：

let promises = [];
querySnapshot.forEach(function (doc) {
  promises.push(
    promiseFunction()
    .then((postCounters) => {
      return promiseFunction2()//missing return here
      .then((myRate) => {
          console.log('save array with postCounters AND myRate data');
          return [postCounters,myRate];//missing return here
      })
    })
  );
})

如果您不需要等待promiseFunction 完成即可开始promiseFunction2，那么您可以这样做：

let promises = [];
querySnapshot.forEach(function (doc) {
  promises.push(
    Promise.all(
      promiseFunction(),
      promiseFunction2()
    )
  );
})

在这两种情况下，结果都是数组数组：

Promise.all(promises)
.then(
  function(results){
    results.forEach(
      function(result){
        console.log("postCounters:",result[0]);
        console.log("myRate:",result[1]);
      }
    )
  }
)