如何将此异步回调转换为生成器？

Question

我很难理解生成器。但我认为我正在尝试做的应该是可能的。

我有一个对象Topic 可以访问Pages。最初Topic 的实现是为了通过回调来检索Pages。

var Topic = function( id ) {

  var repository = new PageRepository();

  this.id = id;
  this.getAllPages = function( callback ) {
    repository.getAllPagesByTopicId( this.id, function( result ) {
      var pages = [];
      while( result.hasNext() ) {
        pages.push( result.next() );
      }
      callback( pages );
    } );
  }
}

var topic = new Topic( 1 );
topic.getAllPages( function( pages ) {
  console.log( pages ) // received Page instances
} );

现在，假设我无法重构 PageRepository 的回调机制，但我确实想重构 Topic 以便我可以通过生成器访问它的页面，而不是通过打回来。这是否可行，没有太多的麻烦？

我知道我可以使用 for...of 语句迭代生成器值，例如：

var topic = new Topic( 1 );
for( let page of topic.pages() ) {  // create the generator
  console.log( page ); // received next Page
}

...所以我想出了以下内容：

var Topic = function( id ) {

  ...

  this.pages = function*() { // refactored getAllPages () to a generator function pages()
    repository.getAllPagesByTopicId( this.id, function( result ) {
      while( result.hasNext() ) {
        yield result.next(); // yield the next Page
      }
    } );
  }
}

但是，这不起作用，可能是因为在回调中调用了yield。

然后，基于我对this article（从“使用生成器......”开始）的（较差的）理解，我认为这可能有效：

var Topic = function( id ) {

  ...

  this.pages = function*() {

    let gen = function*() {}(); // create an inner generator

    // not actually sure why the following wrapper function is needed
    // but something similar is used in mentioned article
    yield function() {
      repository.getAllPagesByTopicId( this.id, function( result ) {
        while( result.hasNext() ) {
          gen.next( result.next() ); // call next() on inner generator
        }
      } );
    }(); // immediately create this mysterious wrapper function
  }
}

不幸的是，这也不起作用。

所以，我想要实现的目标是可行的，没有太多麻烦；含义：没有模块（如 co、suspend 等）和/或复杂的 thunk 生成器，你有什么？

Answer 1

我确实想重构 Topic 以便我可以通过生成器而不是通过回调来访问它的页面。这是可行的，没有太多麻烦吗？

不，不是真的。您在这里混合了两个概念：

• 用于创建产生结果值的迭代器的生成器，类似于result 迭代器
• 滥用生成器来创建产生异步操作的迭代器，该操作从外部异步驱动以允许内部同步控制结构（另请参阅 here for deeper explanation，或继续阅读您链接的 davidwalsh 文章）

一旦第二个获得了自己的关键字 (async/await)，merge the two concepts 就有一些想法，但这还不适用（async iteration proposal 处于第 3 阶段）。您被“嵌套”结构困住了，即异步回调中的类似数组的迭代器。

因此，您可以为其中任何一个使用生成器，但不能同时为两者使用一个生成器。这是否值得值得怀疑。请注意，两者都不会使您的代码同步，在某些方面您总是必须使用异步回调。

---

使用生成器实例回调，而不是数组：

function Topic( id ) {
  var repository = new PageRepository();
  this.id = id;
  this.getAllPages = function( callback ) {
    repository.getAllPagesByTopicId( this.id, function( result ) {
      callback( function* () {
        while( result.hasNext() ) {
          yield result.next();
        }
      }() );
    } );
  }
}

var topic = new Topic( 1 );
topic.getAllPages( function( pageiterator ) {
  for( let page of pageiterator ) {
    console.log( page ); // received next Page
  }
} );

---

不要回调函数，而是恢复生成器（如 最简单的异步示例）：

function Topic( id ) {
  var repository = new PageRepository();
  this.id = id;
  this.getAllPages = function( it ) {
    repository.getAllPagesByTopicId( this.id, function( result ) {
      for (var pages = [], result.hasNext(); ) pages.push( result.next() );
      it.next( pages );
    } );
  }
}

var it = (function *() {
  var topic = new Topic( 1 );
  var pages = yield topic.getAllPages( it );
  console.log( pages ) // received Page instances
}());
it.next();

是的，您可以同时使用这两种方法（将生成器创建的迭代器传递给异步生成器的 next 方法），但这可能会让人很困惑。而且它们将保持独立的生成器。