RxJava 过滤操作符 distinct 和 distinctUntilChanged

distinct  看下文档

distinct  : 过滤掉重复的元素

distinctUntilChanged: 过滤掉连续重复的元素,不连续重复的是不过滤

看下代码

1 distinct

 Observable.just(1,1,2,2,3,3,1,2,3).distinct().subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Throwable {Log.e("--------rxjava",integer.toString());}});

打印结果为

2 distinctUntilChanged 

  Observable.just(1,1,2,2,3,3,1,2,3).distinctUntilChanged().subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Throwable {Log.e("--------rxjava",integer.toString());}});

打印结果为:

总结

以上是生活随笔为你收集整理的RxJava 过滤操作符 distinct 和 distinctUntilChanged的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。