可读流是生产数据用来供程序消费的流。常见的数据生产方式有读取磁盘文件、读取网络请求内容等，看一下前面介绍什么是流用的例子：
const rs = fs.createReadStream(filePath);rs 就是一个可读流，其生产数据的方式是读取磁盘的文件，控制台 process.stdin 也是一个可读流：
process.stdin.pipe(process.stdout);通过简单的一句话可以把控制台的输入打印出来，process.stdin 生产数据的方式是读取用户在控制台的输入。
回头再看一下对可读流的定义：可读流是生产数据用来供程序消费的流。
除了系统提供的_** fs.CreateReadStream**_ 使用过 gulp 或者 vinyl-fs 提供的 src 方法时候也在使用可读流
gulp.src(['*.js', 'dist/**/*.scss'])如果希望自己以某种特定的方式生产数据，交给程序消费，那么改如何开始呢？
简单两步即可
继承 sream 模块的 Readable 类
重写 _read 方法，调用 this.push 将生产的数据放入待读取队列
Readable 类已经把可读流要做的大部分工作完成，只需要继承它，然后把生产数据的方式写在 _read 方法里就可以实现一个自定义的可读流。
举个例子：实现一个每 100 毫秒生产一个随机数的流（没什么用处）
类继承部分代码很简单，主要看一下 _read 方法的实现，有几个值得注意的地方
Readable 类中默认有 _read 方法的实现，不过什么都没有做，我们做的是覆盖重写
_read 方法有一个参数 size，用来向 read 方法指定应该读取多少数据返回，不过只是一个参考数据，很多实现忽略此参数，我们这里也忽略了，后面会详细提到
通过 this.push 向缓冲区推送数据，缓冲区概念后面会提到，暂时理解为挤到了水管中可消费了
push 的内容只能是字符串或者 Buffer，不能是数字
push 方法有第二个参数 encoding，用于第一个参数是字符串时指定 encoding
执行一下看看效果
这样可以看到数字源源不断的显示到了控制台上，实现了一个产生随机数的可读流，还有几个小问题待解决
每隔 100 毫秒向缓冲区推送一个数字，那么就像读取一个本地文件总有读完的时候，如何停下来标识数据读取完毕？
向缓冲区 push 一个 null 就可以，修改一下代码，允许消费者定义需要多少个随机数字：
代码中使用了一个 max 的标识，允许消费者指定需要的字符数，在实例化的时候指定即可
const RandomNumberStream = require('./RandomNumberStream'); const rns = new RandomNumberStream(5); rns.pipe(process.stdout);这样可以看到控制台只打印了 5 个字符
细心的同学可能注意到，每隔 100 毫秒生产一个随机数并不是调用的 setInterval，而是使用的 setTimeout，为什么仅仅是延时了一下并没有重复生产，结果却是正确的呢？
这就需要了解流的两种工作方式
流动模式：数据由底层系统读出，并尽可能快地提供给应用程序
暂停模式：必须显示地调用 read() 方法来读取若干数据块
流在默认状态下是处于暂停模式的，也就是需要程序显式的调用 read() 方法，可上面例子中并没有调用就可以得到数据，因为流通过 pipe() 方法切换成了流动模式，这样 _read() 方法会自动被反复调用，直到数据读取完毕，所以每次 _read() 方法里面只需要读取一次数据即可
流从默认的暂停模式切换到流动模式可以使用以下几种方式：
通过添加 data 事件监听器来启动数据监听
调用 resume() 方法启动数据流
调用 pipe() 方法将数据转接到另一个可写流
从流动模式切换为暂停模式又两种方法：
在流没有 pipe() 时，调用 pause() 方法可以将流暂停
pipe() 时移除所有 data 事件的监听，再调用 unpipe() 方法