rx-java - RXJava 在等待订阅者完成后丢弃并仅发出最新消息

Question

我在订阅者中有耗时的过程。因此，在处理此过程时，还会有其他传入消息。但是这个消息是一种触发器，不包含任何状态。因此，不需要处理所有消息。当订阅者完成当前消息时，处理最新消息就足够了。

我尝试了几种方法。

1. 配置背压策略drop。但是，这是行不通的，因为 RXJava 有内部缓冲区，并且背压仅在达到该数量时才会丢弃消息。
2. ThrottleLast、Debounce、..etc 取决于时间段，因此即使订阅者完成工作，它也会等待。订户完成工作后，我需要立即获取最新信息。

标签： rx-javarx-java2vert.xrx-java3