Q 承诺传播错误和异常

Question

我正在使用此代码将经典的 nodejs 函数转换为 Promise 函数：

  Object.defineProperty(Function.prototype, "toPromise", {
    enumerable: false,
    configurable: false,
    writable: false,
    value: function(self) {
      var $this;
      $this = this;
      return function() {
        var arg, args, deferred, _i, _len;
        deferred = Q.defer();
        args = [];
        for (_i = 0, _len = arguments.length; _i < _len; _i++) {
          arg = arguments[_i];
          args.push(arg);
        }
        args.push(function() {
          args = Array.prototype.slice.call(arguments);
          if (args[0] instanceof Error) {
            return deferred.reject.apply($this, args);
          } else {
            return deferred.resolve.apply($this, args);
          }
        });
        $this.apply(self, args);
        return deferred.promise;
      };
    }
  });

我在一个函数上调用它来获取另一个函数。像这样：

  exports.list = (function(userid, options, callback) {
    // do something 
    // success ->
        callback(data);
    // error ->
        callback(err)
  }).toPromise(this);

但是当一个不是我抛出的异常（SyntaxError、TypeError...）被抛出时，then 或fail 函数不会被调用。如何自动传播？

我试图用它替换 toPromise 但这没有用（即使它与我的函数一起使用）

  Object.defineProperty(Function.prototype, "toPromise", {
    enumerable: false,
    configurable: false,
    writable: false,
    value: function(self) {
      var $this;
      $this = this;
      return Q.denodeify(this.bind(Kitty));
    }
  });

我还尝试对then 应用第二个回调，但我也没有工作。

Answer 1

但是当一个不是我抛出的异常（SyntaxError、TypeError...）被抛出时，则不会调用 then 或 fail 函数。

Q 只捕获从.then() 回调中抛出的异常。您需要自己明确处理所有其他异常。

如何自动传播？

如果异常是从您自己的代码中抛出的，您可以考虑在较低级别上使用 Promises，并将您自己的代码仅放在 then 回调中。

如果异常是从您调用的“经典 nodejs 函数”中抛出的，则需要 catch 它。但是，抛出异常（这是相当不可恢复的）而不是仅使用错误参数调用回调可能有充分的理由，这将是异步节点函数的“正常”设计方法。

如果您想在 toPromise 方法中包含此类功能，则需要包装函数调用：

try {
  $this.apply(self, args);
} catch(e) {
  deferred.resolve(e);
}

---

(function(…, callback) { … }).toPromise(this);

这是个坏主意。你不应该在你自己的函数上使用toPromise，而只能使用那些给你的并且具有非承诺接口的函数。请参阅教程部分中的The Beginning 如何设计一个真正返回 Promise 的函数。不要使用callback 变量。太容易一些错误逃脱了你。尤其是如果你有一个已经产生了 Promise 的函数，你需要做的就是在它之后链接其他任务。

在你的具体情况下，它只是

exports.list = function(userid, options) {
  return canThis(userid, "mod", "browse").then(function(can) {
    if (can === false)
      throw error.throwError("Forbidden", "UNAUTHORIZED");
    if (options.perPage > 50) {
      throw error.throwError("Too much mods per page", "INVALID_PARAMS");

    var Mod = mongoose.model("Mod");
    return Q.all([ // I would assume that listing and counting can happen in parallel?
      Q.ninvoke(Mod, "list", options),
      Q.ninvoke(Mod.count(), "exec")
    ]).spread(function(mods, count) {
      mods.totalCount = count;
      return mods;
    }, function(err) { // and throw this error when one happens in either?
      throw error.throwError(err, "DATABASE_ERROR");
      // not sure whether you need errors.handleResult at all
      // (not with a callback, at least)
    });
  });
};

现在所有returns 都说得通了。