RxJava:丢弃物品?- 背压

Pau*_*hek 1 java backpressure rx-java

我使用RxJava观察几个按钮上的点击.

这些订阅将在一个对象上调用不同的函数,这需要几毫秒.这些功能是同步的.

问题是,当按下太多按钮时,我会得到一个背压异常.对我来说有用的是丢弃几个输入(最好是oldes).RxJava可以吗?

Reu*_*ani 5

这是onBackPressureDrop()用于:

指示一个Observable发射物品的速度比它的观察者可以消耗它们更快,以丢弃而不是发射它观察者不准备观察的那些物品.

onBackPressureDrop()