rxjava切换线程避免重复代码_移动开发_编程开发_程序员俱乐部

中国优秀的程序员网站程序员频道CXYCLUB技术地图
热搜:
更多>>
 
您所在的位置: 程序员俱乐部 > 编程开发 > 移动开发 > rxjava切换线程避免重复代码

rxjava切换线程避免重复代码

 2017/10/25 9:55:57  I-for-code-crazy  程序员俱乐部  我要评论(0)
  • 摘要:.subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(subscriber);每次切换线程的操作变换封装操作Observable.TransformerschedulersTransformer(){returnnewObservable.Transformer(){@OverridepublicObjectcall
  • 标签:Java 代码 线程
.subscribeOn(Schedulers.io())
.unsubscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(subscriber);

每次切换线程的操作

 

变换封装操作

Observable.Transformer schedulersTransformer() {
        return new Observable.Transformer() {
            @Override
            public Object call(Object observable) {
                return ((Observable)  observable).subscribeOn(Schedulers.io())
                        .unsubscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread());
            }
        };
    }

使用的时候

RetrofitClient.singletonDemoService("http://api/data/")
.requestNet("xx","1")
.compose(schedulersTransformer())
.subscribe(subscriber);

水一波

发表评论
用户名: 匿名