转自:
【Android】勤用RXJava compose操作符消除重复代码
1. 问题背景:
想要给多个流重复应用"一系列"相同的操作符,该怎么办???,比如,我们使用Rx+Retrofit进行网络请求时,都有遇到这样场景:要在io线程中请求数据,在主线程订阅,更新UI,所以必须频繁使用下面这样的代码:
...
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(consumer)
...
,如果我们将"让"些操作符,连续的,可重复的 应用到所有流上,同时保持这rx的链式写法,岂不美滋滋...
这时候compose操作符就派上用处了.
2. compose()操作符:
2.1 compose() 源码:
public final <R> Observable<R> compose(ObservableTransformer<? super T, ? extends R> composer) {
return wrap(((ObservableTransformer<T, R>) ObjectHelper.requireNonNull(composer, "composer is null")).apply(this));
}
compose 区分于lift(lift是map,flatMap等操作符的根本),compose,是对ObservableSource本身进行操作的,上面的apply(this),里面this就是代表ObservableSource自己,而lift是对ObservableSource发送的数据进行操作的,
compose(transformer) 接收一个参数ObservableTransformer ,
transformer是一个接口,我们实现它,为了避免Object -> Observable的强转,我们在方法里定义了泛型,这个结合自己的返回数据和逻辑自行修改
public class RxSchedulers {
static final ObservableTransformer schedulersTransformer = new ObservableTransformer() {
@Override
public ObservableSource apply(Observable upstream) {
return upstream
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
};
public static <T> ObservableTransformer<T, T> applySchedulers() {
return (ObservableTransformer<T, T>) schedulersTransformer;
}
}
其中,apply方法里的签名(参数) Observable upstrem,即我们上面的this,即我们要将一系列变换应用在它上面,返回的Observable 就是应用一些列变换之后的Observable.
2.2: 应用:
在代码中,如下使用:
server.requestXXX()
.homeBanners()
//线程切换 封装
.compose(RxSchedulers.<JavaBean>applySchedulers())
至此,我们就将网络请求过程的线程切换封装了.
3: RxLifeCycle
RxLifeCycler,是对请求的生命周期进行处理,避免内存泄露的,其内部实现原理也是基于compose(transformer)的.
具体的源码解析和使用方法,网上已经有很多大神讲解过了,这里不多赘述.
推荐几个RxLifeCycle的文章
RxAndroid之Rxlifecycle使用
RxJava2+Retrofit2+RxLifecycle2使用MVP模式构建项目
