new stream.Transform([options])

• options <Object> 传给 Writable 和 Readable 构造函数。还有以下字段:

  \options <Object> Passed to both Writable and Readable constructors. Also has the following fields:

  • transform <Function> stream._transform() 方法的实现。

    \transform <Function> Implementation for the stream._transform() method.

  • flush <Function> stream._flush() 方法的实现。

    \flush <Function> Implementation for the stream._flush() method.

const { Transform } = require('node:stream');
class MyTransform extends Transform {
 constructor(options) {
 super(options);
 // ...
 }
} 拷贝

或者,当使用 ES6 之前的样式构造函数时:

\Or, when using pre-ES6 style constructors:

const { Transform } = require('node:stream');
const util = require('node:util');
function MyTransform(options) {
 if (!(this instanceof MyTransform))
 return new MyTransform(options);
 Transform.call(this, options);
}
util.inherits(MyTransform, Transform); 拷贝

或者,使用简化的构造函数方法:

\Or, using the simplified constructor approach:

const { Transform } = require('node:stream');
const myTransform = new Transform({
 transform(chunk, encoding, callback) {
 // ...
 },
}); 拷贝