实现一个自定义双工流 Duplex
1、创建自定义可双工流的类 MyDuplex
双工流的可以理解为即可读又可写的流，创建一个类名为 MyDuplex ，并继承 stream 中的 Duplex 类，由于双工流即可读又可写，需重写 _read 和 _write 方法。
let { Duplex } = require("stream");
// 创建自定义双工流的类
class MyDuplex extends Duplex {
// 重写自定义的双工流的 _read 方法
_read() {
this.push("123");
this.push(null);
}
// 重写自定义的双工流的 _write 方法
_write(chunk, encoding, callback)) {
callback();
}
}双工流分别具备 Readable 和 Writable 的功能，但是读和写互不影响，互不关联。
2、验证自定义双工流
let myDuplex = new MyDuplex();
myDuplex.on("readable", () => {
console.log(myDuplex.read(1), "----");
});
setTimeout(() => {
myDuplex.on("data", data => {
console.log(data, "xxxx");
});
}, 3000);
// <Buffer 31> ----
// <Buffer 32> xxxx
// <Buffer 32> ----
// <Buffer 33> xxxx如果 readable 和 data 两种读取方式都使用默认先通过 data 事件读取，所以一般只选择一个，不要同时使用，可读流的特点是读取数据被消耗掉后就丢失了（缓存区被清空），如果非要两个都用可以加一个定时器（绝对不要这样写）。
实现一个自定义转化流 Transform
1、创建自定义可转化流的类 MyTransform
转化流的意思是即可以当作可读流，又可以当作可写流，创建一个类名为 MyTransform ，并继承 stream 中的 Transform 类，重写 _transform 方法，该方法的参数和 _write 相同。
let { Transform } = require('stream');
// 创建自定义转化流的类
class MyTransform extends Transform {
// 重写自定义的转化流的 _transform 方法
_transform(chunk, encoding, callback)) {
console.log(chunck.toString.toUpperCase());
callback();
this.push('123');
}
}在自定义转化流的 _transform 方法中，读取数据的 push 方法和 写入数据的 callback 都可以使用。
2、验证自定义转化流
// demo.js
let myTransForm = new MyTransform();
// 使用标准输入
process.stdin.pipe(myTransForm).pipe(process.stdin);打开命令行窗口执行 node demo.js ，然后输入 abc ，会在命令窗口输出 ABC 和 123 ，其实转换流先作为一个可写流被写入到标准输入中，而此时 stdin 的作用是读流，即读取用户的输入，读取后转换流作为一个可读流调用 pipe ，将用户输入的信息通过标准输出写到命令行窗口，此时 stdout 的作用是写流。
