android接口去重,RxJava2 / RxAndroid2操作符distinct去重
RxJava2 / RxAndroid2操作符distinct去重
distinct去除重复的数据,例如:
package zhangphil.app; import android.os.Bundle; import android.support.annotation.Nullable; import android.support.v7.app.AppCompatActivity; import android.util.Log; import io.reactivex.Observable; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.disposables.CompositeDisposable; import io.reactivex.observers.DisposableObserver; import io.reactivex.schedulers.Schedulers; public class MainActivity extends AppCompatActivity { private final String TAG = getClass().getSimpleName(); private CompositeDisposable mCompositeDisposable = new CompositeDisposable(); private Integer[] test_data = { 1, 2, 2, 3, 4, 5, 5, 6, 7, 7, 8, 9 }; //故意设置若干重复的数据,等待去重复数据 @Override public void onCreate(@Nullable Bundle savedInstanceState) { super.onCreate(savedInstanceState); test(); } private void test() { DisposableObserver disposableObserver = new DisposableObserver() { @Override public void onNext(Integer i) { Log.d(TAG, "#####开始#####"); Log.d("数据", String.valueOf(i)); Log.d(TAG, "#####结束#####"); } @Override public void onComplete() { Log.d(TAG, "onComplete"); } @Override public void onError(Throwable e) { Log.e(TAG, e.toString(), e); } }; Observable observable = Observable.fromArray(test_data); mCompositeDisposable.add(observable .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .distinct() .subscribeWith(disposableObserver)); } @Override protected void onDestroy() { super.onDestroy(); // 如果退出程序,就清除后台任务 mCompositeDisposable.clear(); } }
代码输出:
05-18 10:19:32.361 2346-2346/zhangphil.app D/MainActivity: #####开始##### 05-18 10:19:32.361 2346-2346/zhangphil.app D/数据: 1 05-18 10:19:32.361 2346-2346/zhangphil.app D/MainActivity: #####结束##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 2 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 3 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 4 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 5 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 6 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 7 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 8 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####开始##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/数据: 9 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: #####结束##### 05-18 10:19:32.362 2346-2346/zhangphil.app D/MainActivity: onComplete
android接口去重,RxJava2 / RxAndroid2操作符distinct去重相关推荐
- Access SQL distinct 去重失效问题
今天碰到一个很奇怪的问题,开发的一个考试系统采用Access数据库作为题库,里面建了类似下面这样的临时表用于导入Excel格式的题库: 临时表 ID(自增,长整型) 专业(文本) 科目(文本) 题型( ...
- Database之SQLSever:SQL命令实现四则运算、desc降序、like模糊查询、distinct去重、MAX/MIN/SUM/AVG/COUNT/GROUP/having等案例之详细攻略
Database之SQLSever:SQL命令实现四则运算.desc降序.like模糊查询.distinct去重.MAX/MIN/SUM/AVG/COUNT/GROUP/having等案例之详细攻略 ...
- Linq distinct去重方法之一
var result = query.Distinct().ToList(); List<DeliveryOrderViewModel> dov = result.GroupBy( p = ...
- list集合用stream流distinct去重失效问题
使用Stream distinct()去重实体类List失效问题 注意:这里用的是 filter实现 根据某个属性对实体list去重 思路: 1.创建用于接受临时数据的list. 2.在filter中 ...
- 使用Stream distinct()去重失效问题
使用Stream distinct()去重实体类List失效问题 注意:这里用的是 filter实现 根据某个属性对实体list去重 思路: 1.创建用于接受临时数据的list. 2.在filter中 ...
- MySQL学习(8)︱DISTINCT去重与表连接
DISTINCT去重 distinct用于在查询中返回列的唯一不同值(去重复),支持单列或多列.在实际的应用中,表中的某一列含有重复值是常见的,如employee表的dept列.如果在查询数据时,希望 ...
- distinct去重用法
distinct去重用法 distinct distinct 语法 : select distinct 字段1 , 字段2- from 表名 distinct 作用 : 去重 , 当字段名有多个时需完 ...
- SQLSever 第二堂课,主要学习内容为top查询前多少行,distinct去重,order by排序,group by分组,最重要子查询...
go update xueshengxinxi set name='你好' where code=1--修改第一行name的名字,改成"你好" update xueshengxin ...
- 大数据Spark面试,distinct去重原理,是如何实现的
最近,有位朋友问我,distinct去重原理是怎么实现的? "在面试时,面试官问他了解distinct算子吗?" "了解啊,Spark的rdd,一种transFormat ...
最新文章
- AI都会写灵魂Rap了?Transformer跨界说唱,节奏、流畅度都不在话下
- Android项目导出jar包的小技巧
- git clone -b master https://github.com/hyperledger/fabric-samples.git
- PHP的闭包函数匿名函数
- yelee主题中加入revolvermaps插件
- Helm 3 完整教程(十):Helm 函数讲解(4)加密函数、编码和解码函数
- 使用pyinstaller讲python文件打包成exe文件运行时,弹出命令行界面
- 【笔记】c c++如何打印变量地址
- p104规约测试软件,基于IEC60870-5-104规约的智能配电网终端设备测试方案及软件设计...
- 按摩器具抽查三成不合格 选购需注意哪些?
- 2021年中国DevOps现状调查报告发布!
- 软件测试人员常用的sql语句(四)
- 系统重构过程中的异构数据同步回环处理
- 高老师的架构设计_隽语集(AA_0151)
- 哈佛结构与冯诺依曼结构(含STM32系统结构解析)
- 计算机二级请假条,请假条的范文标准版
- Matlab矩阵论矩阵分析计算实现(四)求史密斯标准型和约当标准型
- 计算机与科学hh,Mary-第十六届和谐人机环境联合学术会议 (HHME2020)
- 2012年中国兽药50强企业
- 使用@WebFilter指定urlPatterns失效问题