使用RxJava跳过最后一个副本

vac*_*ach 6 java reactive-programming rx-java

假设我们有一个主题用于发布一些事件

subject.onNext(...)
Run Code Online (Sandbox Code Playgroud)

最终订阅者通过一个Observable订阅,该Observable是根据这个主题创建的......

我想知道我们是否可以为observable添加一些逻辑,这样如果它获得相同的值它就不会将它传播给订阅者......或者更复杂......?

是否有可能在向订阅者发布值之前创建一个可执行某些代码的主题的observable?

Vla*_*nov 11

还有一个distinctUntilChanged,如果它是在连续发出超过一旦跳过值操作.

如果您需要更多一般行为并希望根据某些条件跳过值,那么filter您可能正在寻找它.