RxJava 2:有关因背压而丢弃的消息的统计信息?
RxJava 2: Stats about messages dropped because of BackPressure?
我正在使用带有 DROP BackPressure 策略的 RxJava 2 Flowable。
有没有什么方法可以收集关于有多少消息因为背压而被丢弃的信息/统计数据?
解决方案
Flowable#onBackpressureDrop(consumer -> {});
http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html#onBackpressureDrop(io.reactivex.functions.Consumer)
有一个重载需要一个 onDrop 处理程序,您可以使用它来进行计数。
通常,建议检查运算符的重载以获取附加功能。
我正在使用带有 DROP BackPressure 策略的 RxJava 2 Flowable。 有没有什么方法可以收集关于有多少消息因为背压而被丢弃的信息/统计数据?
解决方案
Flowable#onBackpressureDrop(consumer -> {});
http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html#onBackpressureDrop(io.reactivex.functions.Consumer)
有一个重载需要一个 onDrop 处理程序,您可以使用它来进行计数。
通常,建议检查运算符的重载以获取附加功能。