在 RxJava 中过滤信号边缘
Filter on signal edge in RxJava
给出
Observable.just(false, true, true, false, false, true, false);
如何创建一个新的 Observable,使其仅在源 Observable 从 false 转换为 true 时发出值?
source.distinctUntilChanged().filter(x -> x).map(x -> "false -> true")
distinctUntilChanged
删除相邻的重复项,filter
只留下真实值。
如果源 observable 可以以真值开始,并且不能被解释为转换,在 distinctUntilChanged
.
之前添加 skipWhile(x -> x)
给出
Observable.just(false, true, true, false, false, true, false);
如何创建一个新的 Observable,使其仅在源 Observable 从 false 转换为 true 时发出值?
source.distinctUntilChanged().filter(x -> x).map(x -> "false -> true")
distinctUntilChanged
删除相邻的重复项,filter
只留下真实值。
如果源 observable 可以以真值开始,并且不能被解释为转换,在 distinctUntilChanged
.
skipWhile(x -> x)