RxJava 学习04 Observable实战

RxJava 学习04 Observable实战

RxJava 学习04 Observable实战

RxJava 学习04 Observable实战

Spring MVC 修改处理返回值的handler

RxJava 学习04 Observable实战

 

RxJava 学习04 Observable实战

final Observable<?> observable = Observable.class.cast(returnValue);  把Object类型的返回值转化成observable对象

5.2 实现一个汇率查询服务

RxJava 学习04 Observable实战

RxJava 学习04 Observable实战

具体函数getCurrencyRatesObservable实现如下

RxJava 学习04 Observable实战

 

然后在controller层,我们就调用上面实现的service逻辑

RxJava 学习04 Observable实战

5.3 rxjava-web-spring-boot-starter的抽取设计

RxJava 学习04 Observable实战

在设定值之前,做一个Interceptor拦截器

RxJava 学习04 Observable实战

RxJava 学习04 Observable实战

RxJava 学习04 Observable实战

RxJava 学习04 Observable实战

看下核心方法EndConsumerHelper.setOnce()的实现

RxJava 学习04 Observable实战

RxJava 学习04 Observable实战

最后增加对应的handler