如何在JavaScript中使用异步生成器？
如何在JavaScript中使用异步生成器？
提问于 2016-12-28 03:06:28
我有一个api，它将返回一个游标来获取更多的数据。我把它模拟成这样：
function fetch(n) {
return Promise.resolve({
results: [n],
next: next < 10 && n + 1,
})
}我想要做的是弄清楚如何使用async/await和生成器来与这个api交互。
这基本上就是我的原型：
async function* api(url) {
let result = await fetch(url)
yield result
while (result.next) {
result = await fetch(result.next)
yield result
}
}我的想法是，我应该能够创建一个异步生成器，并从该生成器中产生，以便迭代游标：
async function main() {
const gen = api(0)
const zero = await gen.next()
console.log(zero.result)
const one = await gen.next()
console.log(one.result)
const rest = await Promise.all([...gen])
console.log(rest.map(r => r.result))
}综合考虑，我认为这是处理分页数据的一种非常好的方式，并且能够用[...gen]提取所有数据是非常酷的。
唯一的问题是，它不能工作！显然，您不能在function*中使用async
❯❯❯ node --version
v7.0.0
❯❯❯ node --harmony --harmony-async-await async-generator.js
/Users/chetcorcos/code/async-generator.js:11
async function* api(url) {
^
SyntaxError: Unexpected token *
at Object.exports.runInThisContext (vm.js:76:16)
at Module._compile (module.js:545:28)
at Object.Module._extensions..js (module.js:582:10)
at Module.load (module.js:490:32)
at tryModuleLoad (module.js:449:12)
at Function.Module._load (module.js:441:3)
at Module.runMain (module.js:607:10)
at run (bootstrap_node.js:382:7)
at startup (bootstrap_node.js:137:9)
at bootstrap_node.js:497:3但我真的觉得这应该是可能的。我一直在尝试一个名为co的流行库，但我不认为这是我想要的。
有什么办法让这个“异步生成器”的概念发挥作用吗？
回答 2
Stack Overflow用户
发布于 2017-12-15 18:34:31
您可以使用Babel插件transform-async-generator-functions来完成此操作。
其用法如下：
const g = async i => [ 1, 2, 3 ]
.map(x => x * 10 ** i);
const f = async function * () {
for (let i = 0; i < 10; i++) {
const xs = await g(i);
for (const x of xs) {
yield x;
}
}
};
const main = async () => {
for await (const x of f()) {
console.log(x);
}
};
main().catch(e => console.error(e));这里的an example repo展示了如何设置你的项目。
重要的部分是.babelrc文件：
{
"presets": [ "env" ],
"plugins": [ "transform-async-generator-functions" ]
}Stack Overflow用户
发布于 2016-12-28 03:50:39
您可以将调用生成器函数作为参数传递给，而不使用扩展元素，Promise.all()接受yield返回的可迭代作为参数。请注意，Promise.all()不会按顺序解析或拒绝传递的Promise对象，但会以与传递的iterable中的元素相同的顺序返回结果数组。
let api = (value) => {
return new Promise((resolve, reject) => {
setTimeout(() => {
resolve(value)
}, Math.floor(Math.random() * 3500))
})
};
let values = [1, 2, 3];
let results = [];
let gen = function* gen(fn, props) {
let i = 0;
do {
yield fn(props[i]).then(res => {console.log(res); return res});
++i;
} while (i < props.length);
}
Promise.all(gen(api, values))
.then(data => console.log("complete:", data))
.catch(err => console.log(err));
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/41350787
复制相关文章
相似问题
腾讯云开发者
