5

我对节点有点陌生，对 koa 完全陌生。我正在尝试使用生成器对 API 执行异步 Web 请求，但我不知道如何将所有部分放在一起。

作为说明，我使用的是 bluebird，因为我看到了一些例子，这似乎是一个好主意。如果有一种更简单的方法可以在没有蓝鸟的情况下做我想做的事，那也很好。

在我的模块中：

plugin.searchForItem = function * (name) {
  Promise = require('bluebird');
  request = Promise.promisifyAll(require('request'));
  console.log("making request");
  yield request.getAsync('http://apisitegoeshere.com/apicall').then(function * (result) {
    var response = result[0];
    var body = result[1];
    console.log(response.statusCode);
    yield response;
  });
};

我这样称呼它：

search.searchForShow = function (name) {
  data = this.plugins[0].searchForItem(name);
  console.log("search returned: " + data);
  console.log("search returned2: " + JSON.stringify(data.next()));
  console.log("search returned3: " + JSON.stringify(data.next()));
  return data;
};

当我查看控制台时，我看到：

search returned: [object Generator]
making request
search returned2: {"value":{"isFulfilled":false,"isRejected":false},"done":false}
search returned3: {"done":true}

我知道我的代码到处都是，但我已经研究了几个小时，但我仍然没有接近修复它。

谢谢！

4

3 回答 3

4

请不要promisifyAll在运行时代码中调用：这是不必要的，混乱的应用程序逻辑，不属于那里并且非常非常慢。

你需要将方法标记为协程，否则它只是一个生成器。

var Promise = require("bluebird");
// Assumes request is promisified else where, like in your init file
var request = require("request");

plugin.searchForItem = Promise.coroutine(function* (name) {
    var response = yield request.getAsync("http://www.google.com").get(0);
    console.log(response.statusCode);
    return response;
});

协程返回一个 Promise，您可以将其与另一个协程一起使用，或者仅将其用作 Promise。由于您已经在使用生成器，您不妨使用另一个协程：

search.searchForShow = Promise.coroutine(function* (name) {
  var data = yield this.plugins[0].searchForItem(name);
  console.log("search returned: " + data);
  return data;
});
于 2014-12-23T17:01:00.083 回答
1

从那里调用生成器.then不会接近工作。调用生成器只是返回它的迭代器，而不用它做任何事情。你想要的是（未经测试）：

plugin.searchForItem = function * (name) {
  Promise = require('bluebird');
  request = Promise.promisifyAll(require('request'));
  console.log("making request");
  var result = yield request.getAsync('http://apisitegoeshere.com/apicall');
  var response = result[0];
  var body = result[1];
  console.log(response.statusCode);
  yield response;
};

你不需要这样做.then。那是科亚的工作。它将得到你产生的承诺，等待它解析，将解析后的值作为参数传回给iterator.next()，它成为你的变量result，函数将继续到下一个yield（或函数的结尾）。

但是，在您的情况下，不清楚您是否要像在最后一行中所做的那样产生响应。一方面，你必须产生 Promise，所以这可能会导致 Koa 运行时错误。我怀疑你想要的只是

this.body = response;
于 2014-12-23T16:29:55.303 回答
0

您可能会考虑使用现有的请求包装器，例如co-request build 来与构建koa的co库一起使用。

在 koa 中，您会执行以下操作：

// server.js
var request = require('co-request');

app.use(function *(){
    try{
        var result = yield request('http://apisitegoeshere.com/apicall');       
        this.body = result.body;
    }
    catch(err){
        this.throw(500);
    }

});
于 2014-12-23T23:11:14.407 回答