我正在查看JSONStream中的node.js,我正在尝试下面这个小应用程序来获得它的句柄:
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);不幸的是,当在命令行上运行时,这不会将任何东西写入控制台。我做错了什么?
发布于 2013-10-17 20:36:29
如果您重写代码,它就会工作:
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()的输出输送到process.stdout的原因是JSONStream输出对象,而process.stdout只接受字符串(可能还包括缓冲区):
> process.stdout.write({ foo : 1 });
TypeError: invalid data
at WriteStream.Socket.write (net.js:612:11)
...https://stackoverflow.com/questions/19432968
复制相似问题