stream流定义及使用方法

import path from 'path';
import fs, { read } from 'fs';

const filePath = path.join(path.resolve(), 'files', 'text.txt');

const readable = fs.createReadStream(filePath);
// 如果采用 readable.setEncoding() 方法为流特定了默认设置编号，则监控器调整将db块做为字符串数组传到；不然数据信息将成为 Buffer 传到。
readable.setEncoding('utf8');
let str = '';

readable.on('open', (fd) => {
  console.log('逐渐读取文件')
})
// 每每流将db块的使用权移交顾客时，往往会开启 'data' 事情
readable.on('data', (data) => {
  str  = data;
  console.log('载入到数据信息')
})
// 方式可能导致处在流动模式的流终止开启 'data' 事情，转换到中止方式。 一切可利用的数据信息也将保留在内部结构缓冲区域中。
readable.pause();
// 方式使被显式中止的 Readable 流修复开启 'data' 事情，将流转换到流动模式。
readable.resume();
// 当启用 stream.pause() 而且 readableFlowing 并不是 false 时，往往会开启 'pause' 事情。
readable.on('pause', () => {
  console.log('载入中止')
})
// 当启用 stream.resume() 而且 readableFlowing 并不是 true 时，往往会开启 'resume' 事情。
readable.on('resume', () => {
  console.log('再次流动性')
})
// 当流中没有那么多数据信息能够购物时，往往会开启 'end' 事情。
readable.on('end', () => {
  console.log('文件读取结束');
})
// 当流以及一切最底层网络资源（比如文件描述符）已停用时，往往会开启 'close' 事情。
readable.on('close', () => {
  console.log('关掉文件读取')
})
// 将 destWritable 流关联到 readable，使之自动选择到流动模式并把它全部数据推送到关联的 Writable。 数据流分析要被自动管理
readable.pipe(destWriteable)
// 假如最底层流因为最底层内部结构常见故障而难以生成数据，或是当流完成试着消息推送无效数据块时，可能发生这样的事情。
readable.on('error', (err) => {
  console.log(err)
  console.log('文件读取出现错误')
})

import path from 'path';
import fs, { read } from 'fs';

const filePath = path.join(path.resolve(), 'files', 'text.txt');
const copyFile = path.join(path.resolve(), 'files', 'copy.txt');

let str = '';
// 建立能读流
const readable = fs.createReadStream(filePath);
// 如果采用 readable.setEncoding() 方法为流特定了默认设置编号
readable.setEncoding('utf8');

// 建立应写流
const wirteable = fs.createWriteStream(copyFile);
// 编号
wirteable.setDefaultEncoding('utf8');

readable.on('open', (fd) => {
  console.log('逐渐读取文件')
})
// 每每流将db块的使用权移交顾客时，往往会开启 'data' 事情
readable.on('data', (data) => {
  str  = data;
  console.log('载入到数据信息');

  // 载入
  wirteable.write(data, 'utf8');
})

wirteable.on('open', () => {
  console.log('逐渐载入数据信息')
})
// 如果对于 stream.write(chunk) 的启用回到 false，则 'drain' 事情将于适宜再次将它们载入流时开启。
// 即运行数据速度超过读取速度，缓存区放满以后，会中止生产制造着从底层获取数据
// writeable缓存区释放出来以后，会上传一个drain事情让经营者再次载入
wirteable.on('drain', () => {
  console.log('再次载入')
})
// 在启用 stream.end() 方式以后，而且所有数据早已更新到最底层系统软件，则开启 'finish' 事情。
wirteable.on('finish', () => {
  console.log('数据信息载入结束')
})

readable.on('end', () => {
  // 数据读取结束通告应写流
  wirteable.end()
})
// 如在能读流上启用 stream.pipe() 方式将这一应写流导入到其总体目标集时，则开启 'pipe' 事情。
// readable.pipe(destWriteable)
wirteable.on('pipe', () => {
  console.log('管道流建立')
})

wirteable.on('error', () => {
  console.log('数据信息载入出现错误')
})