javascript - 使用事件流结束处理流

Question

我正在使用 JSONStream 读取一个大型 JSON 文件，并且我想在处理整个流时调用一个方法。

var JSONStream = require('JSONStream'), es = require('event-stream');

es.pipeline(
  fs.createReadStream('file.json'),
  JSONStream.parse(['features', true]),
  es.map(function (data) {
    console.log("Added data");
  })
);

我怎样才能做到这一点？

Answer 1

我使用'event-stream'处理约200kB的文件，其中包含JSON，并且在使用'event-stream'时从未调用'end'事件时遇到问题，如果我在event-stream之后放置.on（'end'）管道。但是当我把它放在管道之前 - 一切正常！

stream.on('end',function () {
            console.log("This is the End, my friend");                
     }).on('error',function (err) {
                console.error(err);
     }).pipe(es.split())
       .pipe(es.map(function (line, cb) {
                //Do anything you want here with JSON of line
                return cb();
            }));

nodejs , 事件流

Answer 2

排序。将读取流保存在变量中并在该读取流上传递 on('end', function) 。