对这种流可读语法有点困惑

Question

我通读了流手册，他们有这个例子：

var Readable = require('stream').Readable;

var rs = new Readable;
rs.push('beep ');
rs.push('boop\n');
rs.push(null);

rs.pipe(process.stdout);

看起来正是我所需要的（将对象推入可读流并将其通过管道传输到可写流中。）

这就是我的想法

var Readable = require('stream').Readable;
var rs = new Readable;

app.get('/:foo', function(req, res) {
oboe(fs.createReadStream("/file"))
    .node( "{}", function(data) { 
          rs.push(data) 
     })
rs.pipe(res);

我正在使用双簧管在 fsStream 上侦听对象并对其进行修改。目前我将新发现的对象推入一个数组，然后在“完成”流事件中我会告诉 res.json 新创建的数组。这太重了内存，我想知道我是否可以在找到和修改对象时清空流，将其推送到可读流中，并且当可读流获取数据时，它会将其通过管道输出到 res 但仍保持一个对象。

但是我收到了这个错误

Error: not implemented at Readable._read

这是否意味着直播手册已过时？

Answer 1

您不应该直接使用Readable。你应该继承它并编写自己的_read 实现；这就是为什么节点抱怨 Readable._read 没有实现。此外，节点流需要Strings 或Buffers，而不是JSON Objects，因此将双簧管的node 事件中的data 写入流可能会导致问题。

我认为这里有一个比使用Readable 流更简单的解决方案。听起来您想获取双簧管给您的JSON Object，更改它，然后将其流出express 的res 对象。 res 本身是一个 Writable 流，因此，您可以简单地通过 write 多次访问它，直到完成为止。请注意，当双簧管完成时，您还必须在响应流 (res) 上调用 end()。

app.get('/:foo', function(req, res) {
    oboe(fs.createReadStream("/file"))
        .node( "{}", function(data) { 
            // ... transform data however you need ...
            res.write(JSON.stringify(data)); // Note that data is JSON.stringified here since res.write wants a String or a Buffer, not an Object
        })
        .done(function() {
            res.end();
        })
})

注意： 我假设您在响应的另一端有一些东西可以处理像这样流式传输的 JSON 对象。如果你还没有的话，你可能还需要像双簧管这样的东西。