在回调中使用 $q - 这可能吗？

Question

我用下面的代码创建了一个简单的例子。目标是能够使用来自 Angular 的 $q 服务的 deferred 承诺，但在回调中拥有 $q，该回调本身返回要在主控制器中处理的结果。

我认识到错误显然是$q 的承诺需要立即返回，以便它可以“等待”结果，并且将该承诺放在回调中会阻止它立即返回。因此，下面的代码显然是一个错误的策略。

我的问题是问什么是实现与上述愿望相当的实用程序的最佳实践，包括回调的存在和需要返回一个承诺。

function asyncGreet(name, cb) {
  cb(name)
}

function okToGreet(name) {
  return name.length > 10
}

var promise = asyncGreet('Robin Hood', function(name) {
    var deferred = $q.defer();

  setTimeout(function() {
    deferred.notify('About to greet ' + name + '.');

    if (okToGreet(name)) {
      deferred.resolve('Hello, ' + name + '!');
    } else {
      deferred.reject('Greeting ' + name + ' is not allowed.');
    }
  }, 1000);

  return deferred.promise;
});

promise.then(function(greeting) {
  console.log('Success: ' + greeting);
}, function(reason) {
  console.log('Failed: ' + reason);
});

Answer 1

为了整合 cmets 并解决其他答案对异步 API 的描述有些混乱，我决定提供一个答案：

如果我们假设有一些异步的非承诺/基于回调的 API，例如，asyncGreet，它可以被模拟成这样：

function asyncGreet(name, cb){
  // simulate async
  setTimeout(function(){
    someCondition ? cb({message: "Hello, " + name + "!"}) :
                    cb({error: "Greeting " + name + " is not allowed."});
  }, 2000);
}

（就本示例而言，asyncGreet 是第 3 方 API不受我们控制）

要将其转换为基于 $q 承诺的 API，您将使用 $q（使用 $q.defer 或 $q 构造函数 - 事实上，我刚刚注意到 Angular's documentation shows the $q-constructor approach）。

因此，例如，您可以创建一个greeterSvc 服务：

app.factory("greeterSvc", function greeterSvcFactory($q){
  return {
    greet: function(name){

      return $q(function(resolve, reject){            
        asyncGreet(name, function cb(data){
          if ('error' in data) {
            reject(data.error);    // extract reason
          } else {
            resolve(data.message); // extract greeting message
          }       
        });

      });
    }
  }
})

greeterSvc.greet API 的使用者然后可以.then 它并记录一些东西 - 就像你所做的一样（尽管我会使用 .catch 代替）

greeterSvc.greet("Robin Hood")
          .then(function(greeting) {
             console.log('Success: ' + greeting);
          })
          .catch(function(reason) {
             console.log('Failed: ' + reason);
          });

Answer 2

嗯，我真的想通了。您创建deferred，然后将其传递给回调。在我发布之前对我来说应该很明显，但也许它会帮助像我一样困惑的其他人：

function asyncGreet(name, cb) {
  var deferred = $q.defer();

  setTimeout(function() {
    var foo = null;
    cb(name, deferred)
  }, 1000);

  return deferred.promise;
}

var promise = asyncGreet('Robin Hood', function(name, deferred) { 
  if (name.length > 10) {
    foo = 'Hello, ' + name + '!';
  } else {
    foo = 'Greeting ' + name + ' is not allowed.';
  }
  deferred.resolve(foo);
});

promise.then(function(greeting) {
  console.log('Success: ' + greeting);
}, function(reason) {
  console.log('Failed: ' + reason);
});