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

Question

我正在使用带有节点的数据库。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

所以我在谷歌群组上问了同样的问题：

引用瑞安·保罗的话：

你最初的尝试实际上非常接近，只有两件事你需要补充：

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

下面是一个协同程序和产量的工作示例：

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};
  });
}

只要使用像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]}));
  });
}

Answer 2

屈服不适用于包含promise的对象-它只适用于promise本身。而不是返回屈服{q1：查询，q2： query2}；

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

然而，这有点问题，因为在query2中的错误在query完成之前不会被抛出。所以，如果你不只是想按顺序执行它们，你必须使用Promise。所有“并行”等待一系列promise：

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

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