RxJava 2:由于BackPressure而丢弃的消息的统计信息？

Question

我正在使用带有DROP BackPressure策略的RxJava 2 Flowable。有没有办法收集有关由于BackPressure而实际丢弃了多少消息的信息/统计数据？

解决方案

Flowable#onBackpressureDrop(consumer -> {}); http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html#onBackpressureDrop(io.reactivex.functions.Consumer)

Answer 1

有一个重载需要一个onDrop处理程序，你可以用它来计数。

通常，建议检查操作员的过载以获得附加功能。