异步调用会生成“错误：没有“光纤”就无法等待，即使使用 _wrapAsync

Question

我在流星中使用 RSS 解析器时遇到了问题。这是一个异步调用，所以它不需要被包装，但它似乎仍然不起作用。我认为这是因为匿名 on('readable' 函数在光纤之外，但我看不到如何解决它。

var FeedParser = Meteor.require('feedparser');
var request = Meteor.require('request');

function getBlog(url, parameter, id){

    request(parameter)
        .on('error', function (error) {
            console.error(error);
        })
        .pipe(new FeedParser())
        .on('error', function (error) {
            console.error(error);
        })

        .on('readable', function () {
            var stream = this,
                item;
            while (item = stream.read()) {
                Items.insert(new_item);                
            }
        });
    }

var wrappedGetBlog = Meteor._wrapAsync(getBlog);


Meteor.methods({
    blog: function (url, parameter, id) {
        console.log('parsing blog');
        var items = wrappedGetBlog(url, parameter, id);
    }
});

Answer 1

Meteor._wrapAsync() 期望被包装的函数返回错误和结果给回调。您的函数 getBlog() 没有这样做，因此 _wrapAsync 不是正确的方法。

我之前包装了that function，但使用了Future。

这种方法允许我从 Meteor.method() 调用 feedparser，这不允许异步函数，但您也尝试在可读事件中执行 insert。我认为insert 如果不在光纤中会抱怨。也许这样也是必要的：

var r = request( parameter );
r.on( 'response' , function(){

  var fp = r.pipe( new FeedParser() );  //need feedparser object as variable to pass to bindEnvironment 

  fp.on('readable', Meteor.bindEnvironment( 
    function () {
      var stream = this,
        item;
      while (item = stream.read()) {         
        Items.insert(new_item);                
      }
    }
    , function( error ){ console.log( error );}
    , fp // variable applied as `this` inside call of first function 
  ));
});

---

纤维是另一种选择...

var Fiber = Npm.require( "fibers" );

 .on('readable', function () {
    var stream = this,
        item;
    while (item = stream.read()) {         
        Fiber( function(){
          Items.insert(new_item);
          Fiber.yield();
        }).run();                
    }
});