add

Author: webVueBlog

企业级/流.md

@@ -265,13 +265,95 @@ readable.setEncoding('utf-8');
 readable.on('readable', () => {
  let chunk;
  while (null !== (chunk = readable.read(10))) {
-  console.log
+  console.log(`接收到${chunk.length}字节的数据`);
+  console.log(`接收到的数据是：${chunk}`);
  }
 })
 
 readable.on('end', () =>{
- console.log()
+ console.log('结束')
 })
 ```
 
+使用 readable.read() 处理数据时，while 循环是必需的。只有在 readable.read() 返回 null 之后，才会发生 readable 事件；readable.setEncoding() 用于设置字符编码。默认情况下没有设置字符编码，流数据返回的是Buffer对象。如果设置了字符编码，则流数据返回指定编码的字符串。
+
+调用 readable.setEncoding('utf-8')会将数据解析为UTF-8数据，并返回字符串。
+
+调用 readable.setEncoding('hex')则会将数据编码成 十六进制字符串。
+
+6. readable.unpipe([destination])
+
+解绑之前使用stream.pipe()绑定的可写流。
+
+如果没有指定目标可写流，则解绑所有管道，如果指定了流目标可写流，但它没有建立管道，则不起作用。
+
+```js
+const fs = require('fs');
+
+const readable = fs.createReadStream('data.txt');
+
+const writable = fs.createWriteStream('write-data.txt');
+
+// readable 的所有数据都推送到 write-data.txt
+readable.pipe(writable);
+
+setTimeout(() => {
+ console.log('停止写入数据');
+ readable.unpipe(writable);
+ console.log('收到关闭文件流');
+ writable.end();
+}, 3);
+```
+
+
+## 异步迭代器
+
+可读流中提供了异步迭代器的使用
+
+```js
+const fs = require('fs');
+
+async function print(readable) {
+ readable.setEncoding('utf8');
+ let data = '';
+ // 迭代器
+ for await (const k of readable) {
+  data += k;
+ }
+ console.log(data);
+}
+
+print(fs.createReadStream('file')).catch(console.log);
+```
+
+如果循环以break 或 throw终止，则流将被销毁。
+
+迭代流将完全销毁流，并以大小等于 highWaterMark选项的块读取流。
+
+如果文件的数据少于64kb，则数据将位于单个块中，因为没有为 fs.createReadStream() 提供 highWaterMark 选项。
+
+## 两种读取模式
+
+可读流 运作于 流动模式 flowing 或 暂停模式 paused 两种模式之一。
+
+在流动模式中，数据自动从底层系统读取，并通过 EventEmitter 接口的事件尽可能快地被提供给应用程序。
+
+在暂停模式中，必须显式调用 stream.read() 读取数据块。
+
+所有可读流都开始于暂停模式，可以通过以下方式切换到流动模式。
+
+添加 data 事件句柄
+
+调用 stream.resume()
+
+调用 stream.pipe()
+
+
+
+
+
+
+
+
+