处理多次调用 AngularJS 承诺中的错误

Question

我有一个带有这种异步 API 的 AngularJS 服务：

myService.asyncCall(['id0', 'id3', 'id2']).then(function (complexData) {   
  // handle complexData
}).catch(function (error) {   
  console.log(error); 
});

asyncCall 封装了多个由$q.all 处理的$http 调用。每个$http 请求都可以响应错误，我希望错误由一个catch 处理程序处理。那么如何实现catch处理程序的多次调用呢？

Answer 1

一种方法是在您的服务中单独附加一个 .catch 处理程序：

function asyncCall(urls){
    var calls = urls.map(makeSomeCall).
                map(function(prom){ return prom.catch(e){ /* recover here */});
    return $q.all(calls);
};

另一种方法是实现settle 方法，该方法类似于$q.all，但会跟踪所有结果。盗用我的回答here：

function settle(promises){
     var d = $q.defer();
     var counter = 0;
     var results = Array(promises.length);
     promises.forEach(function(p,i){ 
         p.then(function(v){ // add as fulfilled
              results[i] = {state:"fulfilled", promise : p, value: v};
         }).catch(function(r){ // add as rejected
              results[i] = {state:"rejected", promise : p, reason: r};
         }).finally(function(){  // when any promises resolved or failed
             counter++; // notify the counter
             if (counter === promises.length) {
                d.resolve(results); // resolve the deferred.
             }
         });
     });
})

您可以像这样处理多个承诺：

var promiseArr = ["id0","id3","id2"].map(makePromise);

settle(promiseArr).then(function(results){
    var failed = results.filter(function(r){ return r.state === "rejected"; });
    var failedValues = failed.map(function(i){ return i.value; });
    var done = results.filter(function(r){ return r.state === "fulfilled"; });
     var doneValues = done.map(function(i){ return i.value; }); 
});

这使您可以访问所有承诺的结果，无论它是否失败，并让您更细致地恢复。

您的服务应该处理该聚合，因为它是对所有内容返回承诺的服务。一个例子是：

if(failed.length > 0){
     throw new Error("The following failed..."); // some info about all failed
}

Answer 2

如果我理解正确（最后），这就是你想要实现的目标：

• 输入：
  1. 承诺列表
  2. 当所有承诺都已解决时调用的回调
  3. 每次任何承诺被拒绝时都会调用一个回调

---

• 行为：
  1. 您希望并行执行（不是顺序执行）。
  2. 您希望所有的 Promise 要么被解决要么被拒绝（即，即使一个 Promise 被拒绝，其余的也应该照常继续）。
  3. 您希望只调用一次“最终”回调（接收结果数组 - 无论相应的延迟是解决还是拒绝）。

---

$q.all 应该“增强”以满足您的需求，因为默认情况下：

1. 一旦列表中的任何承诺被拒绝，它就会立即被拒绝。
2. 如果被拒绝，它只返回拒绝原因，不返回结果列表。

---

这是一个可能的实现：

function asyncCall(listOfPromises, onErrorCallback, finalCallback) {

  listOfPromises  = listOfPromises  || [];
  onErrorCallback = onErrorCallback || angular.noop;
  finalCallback   = finalCallback   || angular.noop;

  // Create a new list of promises that can "recover" from rejection
  var newListOfPromises = listOfPromises.map(function (promise) {
    return promise.catch(function (reason) {

      // First call the `onErrroCallback`
      onErrorCallback(reason);

      // Change the returned value to indicate that it was rejected
      // Based on the type of `reason` you might need to change this
      // (e.g. if `reason` is an object, add a `rejected` property)
      return 'rejected:' + reason;

    });
  });

  // Finally, we create a "collective" promise that calls `finalCallback` when resolved.
  // Thanks to our modifications, it will never get rejected !
  $q.all(newListOfPromises).then(finalCallback);
}

另请参阅此short demo。