在RxJava开始实现背压前(请参阅第226页的“背压”部分),处理生产者(Observables)发送速度超过消费者速度(观察者)是一项困难的任务。有相当多的运算符被发明来处理过多的事件,而它们中的大多数都是非常有趣的。有些对于批处理事件非常有用;其他人则在放弃一些活动。本节将介绍这些操作符,包括一些示例。