javascript - ES6 生成器能否生成正常传递给回调/ promise 的数据？

Question

所以如果你有这样的函数:

function* queryDB(query){
    yield db.collection.find(query);
}

据我了解，它将产生 db.collection.find()返回，所以说它返回一个 promise ，然后 queryDB() 应该返回一个带有 promise 作为其中值的可迭代对象，因此可以使用类似 co 的东西将 promise 合并为一个 promise 。有没有办法在不修改 db.collection.find() 的情况下产生将传递给该 promise 的内容？这样我就可以只使用 for-of 循​​环来迭代数据库中的结果？

明确

我在问我是否可以获得传递给传递给 .then() 的函数的参数的 promise 。如

queryDB().then(function(<values>)

但我生成了 <values> 的迭代器.

Answer 1

您只能在生成器内部执行此操作。

function* queryDB(query) {
  // Here is synchrous-like code!
  var rows = yield db.collection.find(query);

  var sum = 0;

  // Use the rows synchrously
  for (var x of rows) {
    sum += x;
  }

  return sum;
}

var sumPromise = doM(queryDB('query example'));

sumPromise.then(console.log.bind(console));

参见 demo (我建议玩这个，看看它在不同情况下返回什么，它会很清楚)。

---

而你不能:

for (var x of db.collection.find(query))
  ...

或者:

for (var x of queryDB('some query'))
  ...

它会像:

for (var x of (new Promise(...)))
  ...

您的生成器/包装器将返回一个 promise 。你只能用它做then。

---

而你不能做:

function* queryDB(query) {
  db.collection.find(query).then(function(values) {
      yield values;
  });
}

最后的解释:

编译器将如何看待这段代码:

function* queryDB(query) {
  db.collection.find(query).then(anonymousFunction);
}

而且 anonymousFunction 不是生成器，所以你不能在那里写 yield。此外，then 中的 Promise 不需要生成器。

另一方面，如果您想使用 for (var x in queryDB())，编译器希望从 queryDB() 返回一个数组。如果您的 queryDB() 是异步的，它将返回一个类似 Promise 的接口(interface)。

如果你切换到更多函数式风格，你可以这样写:

 forEach(queryDB(), function(item) {
    // action on item
 });

如果您现在 promise 的值是一个数组，您可以执行reduce 或map 实现。但在这种情况下，您不需要发电机。

---

doM 实现:

function doM(gen) {
  function step(value) {
    var result = gen.next(value);
    if (result.done) {
      return result.value;
    }
    return result.value.then(step);
  }
  return step();
}

来源:Monads in JavaScript .

forEach 实现:

function forEach(promise, callback) {
  return promise.then(function(iterable) {
    for (var x of iterable) {
      callback(x);
    }
  });
}