我正在使用带有 DROP BackPressure 策略的 RxJava 2 Flowable。 有没有办法收集有关由于 BackPressure 而实际丢弃了多少消息的信息/统计数据?
解决方案
Flowable#onBackPressureDrop(消费者 -> {});
http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html#onBackpressureDrop(io.reactivex.functions.Consumer)
最佳答案
有一个重载,它需要一个可用于计数的 onDrop 处理程序。
通常,建议检查运算符的重载以获取附加功能。
关于observable - RxJava 2 : Stats about messages dropped because of BackPressure?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41661808/