Node.js Streams on(end) 在异步 on(可读) 完成之前完成

Question

我正在使用 Node.js 请求库和 node-feedparser 来捕获提要，并使用 Mongoose 将其发布到 MongoDB 数据库中。

我将帖子信息存储到帖子集合中，并将提要信息存储到提要集合中，但我需要将 post._id 存储在提要集合中名为 feeds._post 的数组中。

我遇到的问题是使用流接口，在所有 feedparser.on('可读') 对数据库的异步调用完成之前调用 feedparser.on('end')，因此我最终在 Post 集合中有 15 个帖子，而 Feed._post 数组中只有 11 个 post._id。

我知道如果这只是简单的 JavaScript，我可以使用异步来确保 .on('end') 等待所有 .on('ready') 完成，但我该怎么做这与流有关？

提前致谢。

db.Feed.findById(feedid, function(error, feed) {

// request.on('response') -> this.pipe(feedparser)

  feedparser.on('readable', function() {
    var post;
    while (null !== (post = this.read())) {
      db.Post.create({ /* post details */ }, function(err, post) {
        feed._post.push(post);
      });
    }
  });

  feedparser.on('end', function() {
    feed.save();
  });

});

Answer 1

您需要跟踪一个计数器和一个布尔值。当“可读”事件第一次触发时增加计数器，当你完成将它保存到数据库时减少计数器。布尔值以一种状态开始，并在“结束”事件触发时切换。例如：

 var processing = 0, done = false;

 var finished = function(){
     if(processing === 0 && done){
         feed.save();
         // ... other stuff
     }
 };

 feedparser.on("readable", function(){
     processing++;
     doStuff(something, function(){
         // something asynchronous         
         processing--;
         finished();
     });
 });

 feedparser.on("end", function(){
     done = true;
     finished();
 });