进击的 RxJava

上篇简单说了 Retrofit 配上 RxJava 一起用，https://www.jianshu.com/p/0c618a7a797e，我们接着再来说说装配上 RxJava 之后到底能解决哪些实际问题呢？

代码简洁

借助 retorfit 加 rxjava，我们就不需要再做其他多余的封装或修改。网络请求写起来就会简单许多，而且结构也清晰。被观察者就是请求的发起，观察者就是请求的回调。

操作符的作用

rxjava 的优势就在于其操作符的使用，我理解的「操作符」就是 rxjava 为我们提供了一系列方法，可以运用在观察者模式中的「被观察者」「观察者」或「订阅过程」之间来控制。实际项目中我遇到过以下几种常见情况，可以用操作符来处理。
1.请求结果需要做数据处理之后，再给页面展示。 「map」操作符，这个操作符就是在请求回来之后直接对数据做处理之后再返回给观察者。

SampleObservable observable = SampleRetrofitManager.getInstance().service.getService();
observable.map(new Function<ResponseBean, Object>() {
            @Override
            public Object apply(ResponseBean responseBean) throws Exception {
                //这里可以处理返回数据，处理完后返回想要的数据，最后可以在 onNext 做后续处理
                return null;
            }
        }).subscribe(new Observer<Object>() {
            @Override
            public void onSubscribe(Disposable d) {
            }

            @Override
            public void onNext(Object o) {
            }

            @Override
            public void onError(Throwable e) {
            }

            @Override
            public void onComplete() {
            }
        });

2.请求结果是做为下一个请求的请求入参。「flatMap」操作符，这个操作符是在遇到串联请求时使用的，当第一个请求返回结果之后，再拿着结果去请求下一个接口。

SampleObservable observable = SampleRetrofitManager.getInstance().service.getFirstService();
observable.flatMap(new Function<ResponseBean, Observable<SampleResp>>() {
            @Override
            public Observable<SampleResp> apply(ResponseBean responseBean) throws Exception {
                //这里接收到第一个请求的返回结果之后，再用来发起第二个请求，也可在发起请求前先做一些数据处理
                return SampleRetrofitManager.getInstance().service.getSecondService(responseBean);
            }
        }).subscribe(new Observer<Object>() {
            @Override
            public void onSubscribe(Disposable d) {
            }

            @Override
            public void onNext(Object o) {
            }

            @Override
            public void onError(Throwable e) {
            }

            @Override
            public void onComplete() {
            }
        });

3.多个请求同时发起，页面的展示需要多个请求结果共同组织。「zip」操作符，当一个页面的数据来自多个请求时，但又是同一个展示页面时，这个操作符就比较合适。它可以让多个请求同时发起，并在各个请求都返回后，统一处理再返回结果给页面展示。

Observable.zip(observable1, observable2, new Bifunction<Response1, Response2, TotalResponse>(){
            @Override
            public TotalResponse apply(Response1 r1, Response2 r2) throws Exception {
                return null;
            }
        }).subscribe(new Observer<TotalResponse>() {
            @Override
            public void onSubscribe(Disposable d) {
            }

            @Override
            public void onNext(TotalResponse response) {
            }

            @Override
            public void onError(Throwable e) {
            }

            @Override
            public void onComplete() {
            }
        });

请求 observable1, observable2 的返回分别是 r1, r2 而页面需要的是 TotalResponse，通过 zip 操作符处理后，请求就变得简单很多，最后只要关心 response 来进行页面展示就好了。
另外关于线程切换，一开始用的时候觉得耗时任务用 Schedulers.newThread() 就够了，但是对比了 Schedulers.io() 之后发现大家更倾向后者（原因在于后者会有线程池来管理线程，虽说从字面意思上看是专门用来处理 io 操作的线程，但用来做一般耗时任务也是可以的），所以我以后也会采用 io() 来代替 newThread()。
目前项目中暂时遇到的情况是上面这些，新的情况后续还会总结。