2019-01-31 2.15 RxJava

2.15.1 观察者模式

• Observable（被观察者）
• Observer（观察者）
• subscribe（订阅）、（事件）
• onComplete(), 事件队列结束
• onNext()发事件, 需要触发onComplete()
• onError(), 事件队列异常

2.15.2 用法

// Observable#create(), 创建事件
// Observable#just(), Observable#from(), 创建事件, 支持数组
// Observable#subscribe(observer), Observable#subscribe(subscriber); 订阅

2.15.3 变换

• map(), 一对一转换 针对数据转换, 如String -> Bitmap, 也可以针对事件对象, 事件队列
• flatMap(),
  1. 传入的事件对象创建Observable对象
  2. 激活这个Observable
  3. 每创建Observable汇入到同一个final Observable, 而这个final Observable统一交给Subscriber的回调
• 原理: lift()

2.15.4 参考文档

给 Android 开发者的 RxJava 详解