在响应式编程中，会有一个数据发布者 Publisher 和数据订阅者 Subscriber，Subscriber 接收 Publisher 发布的数据并进行消费，在 Subscriber 和 Publisher 之间还存在一个 Processor，类似于一个过滤器，可以对数据进行中间处理。
数据发布者（Publisher）主动推送数据给订阅者（Subscriber），触发 onNext 方法。异常和完成时分别触发 one rror 和onComplete 方法。
如果 Publisher 发布消息太快了，超过了 Subscriber 的处理速度，那怎么办？这就是 Backpressure （背压）的由来。
上游生产数据，生产完成后通过管道将数据传到下游，下游消费数据。当下游消费速度小于上游数据生产速度时，数据在管道中积压会对上游形成一个压力，这就是 Backpressure。
Reactive Programming 框架需要提供机制，使得 Subscriber 能够控制消费消息的速度。
