4

请注意，有许多转换流可以做到这一点：

JSON -> JS

但我希望创建一个可以执行以下操作的 Node.js 转换流：

JS -> JSON

我有一个可读的流：

const readable = getReadableStream({objectMode:true});

可读流输出对象，而不是字符串。

我需要创建一个转换流，它可以过滤其中一些对象并将对象转换为 JSON，如下所示：

const t = new Transform({
  objectMode: true,
  transform(chunk, encoding, cb) {
    if(chunk && chunk.marker === true){
       this.push(JSON.stringify(chunk));
     }
    cb();
  },
  flush(cb) {
    cb();
  }
});

但是，由于某种原因，我的转换流不能接受转换方法的对象，只有字符串和缓冲区，我该怎么办？

我尝试添加这两个选项：

  const t = new Transform({
      objectMode: true,
      readableObjectMode: true,  // added this
      writableObjectMode: true,  // added this too
      transform(chunk, encoding, cb) {
        this.push(chunk);
        cb();
      },
      flush(cb) {
        cb();
      }
    });

不幸的是，我的转换流仍然不能接受对象，只能接受字符串/缓冲区。

4

1 回答 1

8

您只需要writableObjectMode: true在转换流上使用。

文档

options <Object> Passed to both Writable and Readable constructors. Also has the following fields:
    readableObjectMode <boolean> Defaults to false. Sets objectMode for readable side of the stream. Has no effect if objectMode is true.
    writableObjectMode <boolean> Defaults to false. Sets objectMode for writable side of the stream. Has no effect if objectMode is true.

您希望转换流的可写部分接受对象，因为对象已写入其中。虽然将从中读取字符串。

查看这个最小的工作示例：

const { Readable, Writable, Transform } = require('stream');

let counter = 0;

const input = new Readable({
  objectMode: true,
  read(size) {
    setInterval( () => {
      this.push({c: counter++});  
    }, 1000);  
  }  
});

const output = new Writable({
  write(chunk, encoding, callback) {
    console.log('writing chunk: ', chunk.toString());
    callback();  
  }  
});

const transform = new Transform({
  writableObjectMode: true,
  transform(chunk, encoding, callback) {
    this.push(JSON.stringify(chunk));
    callback();  
  }  
});

input.pipe(transform);
transform.pipe(output);
于 2018-03-16T21:24:40.520 回答