雁过留声

a tiger in me sniffs roses

0%

reactivex

一个学习ReactiveX不错的地方:Intro to Rx
以作记录:

概念

  • Observable 随时间发射item, 观察者(observer)可以注册到observable,以获得其事件,其实observable调用了observer的方法, 有 onNext, onError, onComplete
  • Operators 逻辑操作observable, 返回一个新的observable
  • Single 特殊的observable, 只有onSuccess, onError
  • Subject , 一种桥或者代理,即是observer又是observable
  • Scheduler, operator通过调度器(Scheduler)来向observer发送通知。SubscribeOn 改变调度器,ObserverOn决定在哪个线程上发送通知

    scheduler 决定action如何执行,如在线程池,新线程或者消息泵,当前线程上

  1. 调度执行action
  2. 调度执行observable上注册的observer
  3. 调度执行observable上发送来的通知
  • AsObservable 将对象转换成更简单的类型(IObservable),去除一些副作用

  • SubscribeOn: 用特定的scheduler指定后台代码(Subscribe的代码,即observer)执行的地方

  • _ObserveOn_:用特定的scheduler指定notification执行的地方