以下举例了一个相当简单(并且有点无意义)的自定义的 Writable 流的实现。 虽然这个特定的 Writable 流的实例没有任何实际的特殊用途,但该示例说明了一个自定义的 [Writable] 流实例的每个必需元素:

    1. const { Writable } = require('stream');
    2. class MyWritable extends Writable {
    3. _write(chunk, encoding, callback) {
    4. if (chunk.toString().indexOf('a') >= 0) {
    5. callback(new Error('数据块是无效的'));
    6. } else {
    7. callback();
    8. }
    9. }
    10. }