-
3.常用操作符查看全部
-
2.常用操作符查看全部
-
1.常用操作符查看全部
-
from 携带一个数组查看全部
-
create just from查看全部
-
create transforming fidding handle error message查看全部
-
学习网站查看全部
-
RxJava 学习资料查看全部
-
subscribeOn()方法用于指定每个Observable(被观察者)对象查看全部
-
AndroidSchedulers:是RxAndroid库提供在安卓平台的调度器(指定观察者在主线程)查看全部
-
Schedulers(调度器):Rxjava坚决多线程问题的机制 种类: .io()//用于IO操作 .computation()//计算型 计算工作默认的调度器 .immediate()//立即执行 在当前线程执行代码指定的工作 .newThread()//开启一个新线程 开启新线程执行任务 .trampoline()//按照顺序来处理的 按顺序处理队列,并运行队列中每一个任务查看全部
-
Catch:捕获异常 onErrorRetrun:正常结束数据流,回调Oncompleted onErrorResumeNext:用正常的数据流代替数据项,自我替换,不可以捕获到异常信息 OnExceptionResumeNext:用正常的数据流代替数据项,自我替换,并且可以捕获到异常信息 Retry:重试去修复,保证数据的正常 Retrywhen:延迟一定时间后报错,当数据发射完成后再发射给观察者查看全部
-
组合型操作符 Zip:将两个数据源根据时间间隔进行组合发射到观察者,当其中一个Observable发送数据结束或者异常后,另一个数据源也会停止发射数据。 Merge:将两个数据源组成一个新数据源发射到观察者(根据时间点先后顺序组合,无序的) StartWith:在当前数据源之前进行前置数据插入 CombineLattest:两个数据源进行结合,时间内两个数据源第一个数据可以组合第二个数据的时间内的所有数据,超过时间则第一个数据进行替换 Join:observableA.join(observableB, observableA产生结果生命周期控制函数, observableB产生结果生命周期控制函数, observableA产生的结果与observableB产生的结果的合并规则 SwithOnNext:两组数据源,当时间重叠时,后一个数据源的重叠对象会覆盖前一个数据源的重叠对象,然后组成一个新数据源发送给观察者查看全部
-
Debounce:操作间隔一段时间未做操作,才会发射数据 Distinct::去重操作符,一个数据列表中去掉重复数据 ElementAt:获取指定位置数据的操作符 Filter:自定义规则过滤数据 First:取列表数据的第一位数据 IgnoreElements:忽略列表的所有数据元素,不回调onnext,只走Onerror和onCompant Last:取数据列表的最后指定位数的数据 Sample:对数据进行取样,取样成功后再发射数据到观察者,定时取样 Skip:跳跃数据项指定数据 SkipLast::跳过数据列表的最后几项 Take:取指定数据 TakeLast:取数据项列表的最后指定几位数据查看全部
-
转换操作符: MAP:一对一类型转换 FlatMAP:一对多类型转换 GroupBy:将同类型数据进行按不同类型分组 Buffer:将同类型数据按个数进行分组 Scan:数据进行相邻累加 window:查看全部
举报
0/150
提交
取消