美文网首页RxJava
Rx - compose()操作符

Rx - compose()操作符

作者: ZHDelete | 来源:发表于2018-08-20 19:51 被阅读641次

转自:

【Android】勤用RXJava compose操作符消除重复代码

使用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模式构建项目

相关文章

  • Rx - compose()操作符

    转自: 【Android】勤用RXJava compose操作符消除重复代码 使用Rxjava的compose()...

  • Rx操作符

    RxJava的操作符太多了,详细的各个操作符的解释可以直接看文档ReactiveX/RxJava文档中文版,这里记...

  • rx操作符

    按功能进行分类 Operators By Category 1.创建Observable Create —以编程方...

  • Rxjava2的操作符 三

    概述:RX的操作符确实不少,本篇将介绍剩余的操作符。 5. 过滤操作符 5.1 filter()通过一定逻辑来过滤...

  • RxJava学习之转换型操作符

    RxJava学习之转换型操作符 标签(空格分隔): RX系列 转换型操作符 下面展示了可用于Observable发...

  • 实现简单的 RxKotlin (下)

    其他的一些操作符... doOnNext ( doOnError doOnCompleted) compose...

  • RxSwift文档六(单元测试)

    单元测试 测试自定义操作符 RxSwift用RxTest为所有操作符测试,位于Rx.xcworkspace项目内的...

  • Android架构师RX响应式编程——Rxjava实战项目教学

    RX定义 Rx是一个函数库,让开发者可以利用可观察序列和LINQ风格查询操作符来编写异步和基于事件的程序 Rx是微...

  • RxJS系列教程(九) 操作异步流

    Rx,不管你是JS,Java,Python还是Swift,玩的就是操作符。每个操作符怎么用,官方文档写得不能再清楚...

  • Rx常用操作符

    常用操作符 Observable.from() 它接收一个集合作为输入,然后每次输出一个元素给subscriber...

网友评论

    本文标题:Rx - compose()操作符

    本文链接:https://www.haomeiwen.com/subject/bwnliftx.html