从 JavaScript 对象创建 Node.js 可读流——最简单的方法

Question

谁能解释为什么我在使用节点 v0.10.21 运行以下代码后出现错误？

我知道我可以 JSON.stringify() 该对象以获得或多或少相同的结果，这里的重点是在 objectMode 设置为 true 时理解 stream.Readable。

错误：

net.js:612
    throw new TypeError('invalid data');
          ^
TypeError: invalid data
    at WriteStream.Socket.write (net.js:612:11)
    at write (_stream_readable.js:583:24)
    at flow (_stream_readable.js:592:7)
    at _stream_readable.js:560:7
    at process._tickCallback (node.js:415:13)
    at Function.Module.runMain (module.js:499:11)
    at startup (node.js:119:16)
    at node.js:901:3

代码：

var stream = require('stream');
var edad = require(__dirname + '/public/edad.json');

var rs = new stream.Readable({ objectMode: true });

rs.push(edad);
rs.push(null);
rs.pipe(process.stdout);

Answer 1

rs 是 objectMode 流，但 process.stdout 不是，因此它期望将 Buffer 实例写入其中。因为它得到了错误的数据类型，所以它抛出了一个错误。

如果您希望能够像这样对对象进行管道传输，则需要有一个支持写入对象和读取缓冲区的中间流。

类似这样的：

var stream = require('stream');
var util = require('util');

function StringifyStream(){
    stream.Transform.call(this);

    this._readableState.objectMode = false;
    this._writableState.objectMode = true;
}
util.inherits(StringifyStream, stream.Transform);

StringifyStream.prototype._transform = function(obj, encoding, cb){
    this.push(JSON.stringify(obj));
    cb();
};


var edad = require(__dirname + '/public/edad.json');

var rs = new stream.Readable({ objectMode: true });
rs.push(edad);
rs.push(null);

rs.pipe(new StringifyStream()).pipe(process.stdout);

Answer 2

正如 loganfsmyth 所说，rs 在 objectMode 中，而 process.stdout 不在。因此，它期望将Buffers/Strings 写入其中，并在收到Object 时抛出TypeError。

我们需要将Objects的流转换成文本，这就是JSONStream要做的事情：

JSONStream = require('JSONStream');
rs.pipe(JSONStream.stringify()).pipe(process.stdout);

Answer 3

我是一个对 Node 了解不多的人（我只需要让我的 Gulp 设置正常工作）。因此，我需要 20 多行代码和像 stream.push(null) 这样的奇怪调用来处理流中的变量这一事实似乎有点疯狂。

这对我有用：

var data = { "prop1": "val1", "prop2": "val2" };
var dest = 'path/to/dest/config.json';
var s = require('stream');

var stream = new s.Readable();
stream.push(JSON.stringify(data));    // stream apparently does not accept objects
stream.push(null);                    // no idea why this is needed, but it is

return stream
    .pipe()                           // whatever you need
    .pipe($.fs.createWriteStream(dest));