到目前为止,我们已经非常熟悉RxJava的基于推送的特性。事件是在流中产生的,稍后由所有订阅者使用。我们从来没有真正注意过如果观察者的速度很慢,并且无法跟上Observable所发出的事件,那么就会发生什么。这一章专门讨论这个问题。

RxJava有两种方式来处理比订阅者更活跃的生产者:

  • 通过内置的运算符实现了各种flow控制机制,如采样和批处理

  • 订阅者可以通过一个称为背压的反馈通道来传播他们的需求,并且只请求他们可以处理的大小。

这两种机制是在本章中描述的。

results matching ""

    No results matching ""