Node.js同步返回多个异步yield的结果

Question

我正在将 rethinkDB 与 node.js 一起使用。以下请求工作正常：

function myFn () {
 return co(function *() {
        let query;

        query = yield r.db("my-db")
            .table("app")
            .filter(r.row("id").eq(id))
            .run(conn);

        return query.toArray();
    });
}

我想异步返回多个yield的结果，但是以下失败：

function myFn () {
 return co(function *() {
        let query, query2;

        query = r.db("my-db")
            .table("app")
            .filter(r.row("id").eq(id))
            .run(conn);


        query2 = r.db("my-db")
            .table("app")
            .filter(...)
            .run(conn);

        return yield {q1 : query, q2 : query2};
    });
}

然后我必须在每个元素上调用toArray()，所以在我做的调用函数上：

 // using ramda.js
  var res = R.map((el) => {
            return el.toArray();
        }, yield myFn);

但是我得到了：

{
  "q1": {
    "isFulfilled": false,
    "isRejected": false
  },
  "q2": {
    "isFulfilled": false,
    "isRejected": false
  }
}

也有些奇怪：

 // this works perfectly
 return q.toArray();

 // this returns the following :
 return {q: q.toArray()};
 "q": {
   "isFulfilled": true,
   "isRejected": false,
   "fulfillmentValue": [  ...  ]
  }

我怀疑我错过了 yield 工作方式的某些内容，那么如何返回多个 yield 结果的已完成结果？

Answer 1

yield 不适用于包含 Promise 的对象 - 它仅适用于 Promise 本身。而不是return yield {q1: query, q2: query2}; 你必须这样做

return {q1: yield query, q2: yield query2};

但是，这有点问题，因为在完成 query 之前不会抛出 query2 中的错误。因此，如果您不使用 just want to sequentially execute them，则必须使用 Promise.all 来“并行”等待一系列承诺：

var [q1, q2] = yield Promise.all([query, query2]);
return {q1, q2};

（根据您使用的 promise 库，可能还有一个辅助函数将对象视为集合，而不仅仅是数组）

Answer 2

所以我在reThinkDB google groups 上问了同样的问题：

引用瑞安·保罗的话：

您最初的尝试实际上非常接近，只有两个 您需要添加的内容：

• 您需要单独生成查询
• 如果您不想获取游标，则需要在查询中转换为数组

这是一个使用协程和 yield 的工作示例：

function myFn() {
  return co(function*() {
    var conn = yield r.connect();
    var query1 = yield r.db("test").table("fellowship")
                        .filter({species: "hobbit"})
                        .coerceTo("array").run(conn);

    var query2 = yield r.db("test").table("fellowship")
                        .filter({species: "human"})
                        .coerceTo("array").run(conn);

    conn.close();

    return {q1: query1, q2: query2};
  });
}

没有协程和 yield 也很简单，并且作为 只要你使用像 bluebird 这样的 promise 库。我会这样做 它：

function myFn1() {
  return r.connect().then(conn => {
    return bluebird.all([
      r.db("test").table("fellowship")
       .filter({species: "hobbit"})
       .coerceTo("array").run(conn),
      r.db("test").table("fellowship")
       .filter({species: "human"})
       .coerceTo("array").run(conn)
    ]).then(items => ({q1: items[0], q2: items[1]}));
  });
}