[TOC]
## rs
> 低于最高水位线就会自动填充触发readable事件
- 
> 读到末尾会触发readable事件
当到达流数据尾部时， 'readable' 事件也会触发。触发顺序在 'end' 事件之前。
事实上， 'readable' 事件表明流有了新的动态：要么是有了新的数据，要么是到了流的尾部。 对于前者， stream.read() 将返回可用的数据。而对于后者， stream.read() 将返回 null。
- 
## ws
> 当一个流不处在 drain 的状态， 对 write() 的调用会缓存数据块， 并且返回 false。 一旦所有当前所有缓存的数据块都排空了（被操作系统接受来进行输出）， 那么 'drain' 事件就会被触发
建议， 一旦 write() 返回 false， 在 'drain' 事件触发前， 不能写入任何数据块
### end方法
ws.end(chunk,[encoding],[callback]);
> 表明接下来没有数据要被写入 Writable 通过传入可选的 chunk 和 encoding 参数，可以在关闭流之前再写入一段数据 如果传入了可选的 callback 函数，它将作为 'finish' 事件的回调函数
### finish事件
```
var writer = fs.createWriteStream('./2.txt');
for (let i = 0; i < 100; i++) {
writer.write(`hello, ${i}!\n`);
}
writer.end('结束\n');
writer.on('finish', () => {
console.error('所有的写入已经完成!');
});
```
## pipe
pipe时 write必须要有回调来消费 不然缓冲区不会-- ，读出来的也就不会放到wirte的缓冲区里
pipe时，如果不消费，ws不会触发`drain`的回调，既不会`resume`，`flowing`状态不会改变和调用`read`，也就不会触发 `data` 回调往 **ws**中写
## readable
```
let fs = require('fs');
let rs = fs.createReadStream('./1.txt',{
start:0,
highWaterMark:3
});
//在真实的情况下，当可读流创建后会立刻进行暂停模式。其实会立刻填充缓存区
rs.on('readable',()=>{
console.log(rs._readableState.length); //3
//当年消费掉一个字节之后，缓存区变成2个字节了
let char = rs.read(1);
console.log(char);
console.log(rs._readableState.length); //2
//但当你一旦发现缓冲区的字节数小于最高水位线了，则会再读最高水位线个字节到缓冲区里
setTimeout(()=>{
console.log(rs._readableState.length);
},50)
});
```
## options参数注意事项
```
let ws = new WriteStream('./2.txt',{ //如果 options 是一个字符串，则它指定了字符编码。
flags:'w'
,highWaterMark:3
,encoding:'utf8'
,fd:null //果指定了 fd，则 WriteStream 会忽略 path 参数并且会使用指定的文件描述符。 这意味着不会触发 'open' 事件
,mode:0o666
,autoClose:true //如果 autoClose 被设置为 true（默认），则在 error 或 end 时，文件描述符会被自动关闭。 如果 autoClose 为 false，则文件描述符不会被关闭，即使有错误。 应用程序需要负责关闭它，并且确保没有文件描述符泄漏。
,start:0
});
```
