1

我正在查看 node.js 中的 JSONStream,我正在尝试使用以下小应用程序来处理它:

var JSONStream = require('JSONStream');
var Stream = require('stream');

var s = new Stream();
s.pipe = function(dest) {
  dest.write('{"foo":1}');
  return dest;
};

var parser = JSONStream.parse(/foo/);
s.pipe(parser).pipe(process.stdout);

不幸的是,在命令行上运行时,这不会向控制台写入任何内容。我究竟做错了什么?

4

1 回答 1

2

如果您重写代码,它会起作用:

var JSONStream = require('JSONStream');
var Stream = require('stream');

var s = new Stream();
s.pipe = function(dest) {
  dest.write('{"foo":1}');
  return dest;
};

var parser = JSONStream.parse();
parser.on('data', function(obj) {
  console.log('obj', obj);
});
s.pipe(parser);

您无法通过管道输出JSONStream.parse()to的原因process.stdoutJSONStream输出对象,并且process.stdout只接受字符串(可能还有缓冲区):

> process.stdout.write({ foo : 1 });
TypeError: invalid data
    at WriteStream.Socket.write (net.js:612:11)
    ...
于 2013-10-17T20:36:29.070 回答