RxJava之操作符(2)

发表于 更新于 分类于 Waline：

参考网址

使用过的操作符

  • concat 连接多个Observables(被观察者)
    concat
    最多有9个参数，但是可以嵌套，传的数据必须是相同类型
  • mergeDelayError 合并发送
    MergeDelayError
    合并两个发送，如果一个出错不马上发送错误，而是延时到都发送完
  • interval 定时循环发送
    interval
  • map 数据类型转换(同步)
    map
  • flatmap 传入数据，生成新的Observable，一般处理异步任务，连接能实现concat功能
    flatmap
  • distinct 过滤去重操作符
    distinct
  • distinct(Func1) 自定义过滤操作符
    distintF1
    可以以其中的某个重复项为过滤条件
  • repeat 重复发送
    repeat
    重复订阅
  • retry 错误重试
    retry
    发送一个错误(onError),重新订阅
  • retryWhen(Func1) 判断错误，根据错误(func1)决定是否重新订阅
    retryWhen
    发送一个错误(onError),通过func1处理错误，决定是否再次订阅
  • Timeout 超时发送一个onError
    Timeout
  • zip 组合
    zip
  • zipwith 组合
    zipwith
    两个都发送onnext后组合，如果另外一个未发，等待组合后才开始发下一个
  • delay 延时发送
    delay