Skip to content
NineF edited this page Apr 13, 2017 · 1 revision

RxJava初步学习

RxJava 让代码逻辑更加的简单

观察者模式 图片

基本实现 1.创建 Observer,除了 Observer 接口之外,RxJava 还内置了一个实现了 Observer 的抽象类:Subscriber

Observer 在 subscribe() 过程中最终会被转换成 Subscriber 对象

2.创建 Observable,内部有个OnSubscribe类,其中含有一个call(subscriber)方法,在Observable被订阅的时候,call方法会被自动调用

3.Subscribe (订阅) observable.subscribe(observer); observable.subscribe(subscriber); 内部实现 public Subscription subscribe(Subscriber subscriber) { subscriber.onStart(); onSubscribe.call(subscriber); return subscriber; }

Clone this wiki locally