到目前为止,我们已经非常熟悉RxJava的基于推送的特性。事件是在流中产生的,稍后由所有订阅者使用。我们从来没有真正注意过如果观察者的速度很慢,并且无法跟上Observable所发出的事件,那么就会发生什么。这一章专门讨论这个问题。
RxJava有两种方式来处理比订阅者更活跃的生产者:
通过内置的运算符实现了各种flow控制机制,如采样和批处理
订阅者可以通过一个称为背压的反馈通道来传播他们的需求,并且只请求他们可以处理的大小。
这两种机制是在本章中描述的。