我使用RxJava观察几个按钮上的点击.
这些订阅将在一个对象上调用不同的函数,这需要几毫秒.这些功能是同步的.
问题是,当按下太多按钮时,我会得到一个背压异常.对我来说有用的是丢弃几个输入(最好是oldes).RxJava可以吗?
这是onBackPressureDrop()用于:
onBackPressureDrop()
指示一个Observable发射物品的速度比它的观察者可以消耗它们更快,以丢弃而不是发射它观察者不准备观察的那些物品.