RxJava操作符大全 |
您所在的位置：网站首页 › rxjava条件操作符 › RxJava操作符大全 |
RxJava操作符大全
|
整理归类了比较全的比较常用的操作符，但不是最全的。还有个别没有添加，欢迎大家交流补充。 
创建操作符
create
完整创建1个被观察者对象（Observable） just 快速创建1个被观察者对象（Observable） 发送事件的特点：直接发送 传入的事件快速创建 被观察者对象（Observable） & 发送10个以下事件 from fromeArray 快速创建1个被观察者对象（Observable） 发送事件的特点：直接发送 传入的数组数据将数组元素一次发射出，可以用来遍历数组 fromIterable 快速创建1个被观察者对象（Observable） 发送事件的特点：直接发送 传入的集合List数据同上，可用来遍历集合 发送事件下列方法一般用于测试使用 // 该方法创建的被观察者对象发送事件的特点：仅发送Complete事件，直接通知完成 Observable observable1=Observable.empty(); // 即观察者接收后会直接调用onCompleted（） // 该方法创建的被观察者对象发送事件的特点：仅发送Error事件，直接通知异常 // 可自定义异常 Observable observable2=Observable.error(new RuntimeException()) // 即观察者接收后会直接调用onError（） // 该方法创建的被观察者对象发送事件的特点：不发送任何事件 Observable observable3=Observable.never(); // 即观察者接收后什么都不调用 延时操作符 定时操作：在经过了x秒后，需要自动执行y操作 周期性操作：每隔x秒后，需要自动执行y操作 delay使得被观察者延迟一段时间再发送事件 // 1. 指定延迟时间 // 参数1 = 时间；参数2 = 时间单位 delay(long delay,TimeUnit unit) // 2. 指定延迟时间 & 调度器 // 参数1 = 时间；参数2 = 时间单位；参数3 = 线程调度器 delay(long delay,TimeUnit unit,mScheduler scheduler) // 3. 指定延迟时间 & 错误延迟 // 错误延迟，即：若存在Error事件，则如常执行，执行后再抛出错误异常 // 参数1 = 时间；参数2 = 时间单位；参数3 = 错误延迟参数 delay(long delay,TimeUnit unit,boolean delayError) // 4. 指定延迟时间 & 调度器 & 错误延迟 // 参数1 = 时间；参数2 = 时间单位；参数3 = 线程调度器；参数4 = 错误延迟参数 delay(long delay,TimeUnit unit,mScheduler scheduler,boolean delayError): 指定延迟多长时间并添加调度器，错误通知可以设置是否延迟 defer直到有观察者（Observer ）订阅时，才动态创建被观察者对象（Observable） & 发送事件 通过 Observable工厂方法创建被观察者对象（Observable） 每次订阅后，都会得到一个刚创建的最新的Observable对象，这可以确保Observable对象里的数据是最新的 > Integer i = 10; // 2. 通过defer 定义被观察者对象 // 注：此时被观察者对象还没创建 Observable observable = Observable.defer(new Callable |
【本文地址】
今日新闻 |
推荐新闻 |