【问题标题】:How to yield from an async callback called from a generator function?如何从生成器函数调用的异步回调中产生?
【发布时间】:2016-05-20 09:56:31
【问题描述】:

我只是在学习 node.js 生成器,我想让生成器从生成器调用的异步方法的回调中产生一个值。以下代码是我当前的示例。第一个生成器 (get_urls) 返回网站某些页面的一系列 URL。它工作正常。

第二个生成器应该使用 unirest 来检索这些网页中的每一个,以便生成器可以返回页面内容。但是,我不知道如何从 unirest.end() 函数的回调中屈服。

可能有一些库可以更全面地执行此操作(并且具有更好的错误处理能力),但我试图了解最低级别,以便当我足够聪明地使用它们时,我可以从库中获得更多。

#!/usr/local/bin/node
// -*- mode: Javascript; -*-

var unirest = require( 'unirest' );

for (var url of get_urls( 'http://www.example.com/generated-page?n=1' ))
    console.log( 'Get url', url );

for (var page of get_pages( 'http://www.example.com/generated-page?n=1' ))
    console.log( 'Got page', page );

function* get_urls( url ) {
    do {
        yield url;
        var rx = url.match( /^(.*?n=)([0-9]+)$/ );
        if (rx) {
            if (rx[2] >= 3) break;
            url = rx[1] + (parseInt(rx[2]) + 1).toString( );
        }
    } while (rx);
}

function* get_pages( url ) {
    do {
// *** This is what I want to do, but it's not the right way to do it! ***
//      unirest.get( url ).end( function (rsp) { yield rsp; } );
        var rx = url.match( /^(.*?n=)([0-9]+)$/ );
        if (rx) {
            if (rx[2] >= 3) break;
            url = rx[1] + (parseInt(rx[2]) + 1).toString( );
        }
    } while (rx);
}

【问题讨论】:

标签: javascript node.js asynchronous generator yield


【解决方案1】:

yield 只能让位于立即包含它的生成器function*。因此,您不能从回调中屈服。

你可以从回调中做的是解决一个 Promise,你的生成器函数可以产生它。

您的答案有相当多的无关代码(还有为什么在有 native Fetch 等时使用 unirest),所以这里有一个示例(来自我的 another answer),它说明了重复产生承诺的概念:

async function* fetchUrls() {
  let i = 0;
  while (i < 10)
    yield new Promise((resolve, reject) => {
      setTimeout(() => resolve(i++), 200);
    });
}

(async function main() {
  // for-await-of syntax
  for await (const result of fetchUrls())
    console.log(result);
}());

新的for-await-of 语法从 Node v9.2 开始可用,并且可以在 Node v10 或更高版本中使用,无需任何标志。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2020-04-23
    • 1970-01-01
    • 2010-12-20
    • 2016-06-01
    • 1970-01-01
    • 2018-05-02
    • 2020-01-02
    • 2018-11-24
    相关资源
    最近更新 更多