RxJava实用工具类-RxSchedulers(线程调度)

RxJava在Android开发中以及非常的普遍了，网上对应的资料也非常的多，这里就不多做介绍了，这里主要写一下RxJava的线程转换

用RxJava结合Retrofit网络请求接口一般的写法如下

RetrofitManager.create(ApiService.class)
        .login(username, password)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Consumer<DataResponse<User>>() {
            @Override
            public void accept(DataResponse<User> response) throws Exception {
                if (response.getErrorCode() == 0) {
                    mView.loginSuccess(response.getData());
                } else {
                    mView.showFaild(String.valueOf(response.getErrorMsg()));
                }
            }
        }, new Consumer<Throwable>() {
            @Override
            public void accept(Throwable throwable) throws Exception {
                mView.showFaild(throwable.getMessage());
            }
        });
    

其中subscribeOn(Schedulers.io())和observeOn(AndroidSchedulers.mainThread())可以清楚的看到线程之间的切换(具体的函数用法请移步RxJava2大全)

但是一般在实际开发中，我们所用到的接口和耗时操作处理是非常多的，每次都要写上这么两行也是非常烦人，所以需要用新的方式用一行代码去实现线程切换

代码如下：

/**
 * 通用的Rx线程转换类
 * 参考:http://www.jcodecraeer.com/a/anzhuokaifa/androidkaifa/2015/0819/3327.html
 */
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;
    }
}

有了这个工具类之后，在请求网络接口的时候就可以这么写了

RetrofitManager.create(ApiService.class)
                .login(username, password)
                .compose(RxSchedulers.<DataResponse<User>>applySchedulers())
                .subscribe(new Consumer<DataResponse<User>>() {
                    @Override
                    public void accept(DataResponse<User> response) throws Exception {
                        if (response.getErrorCode() == 0) {
                            mView.loginSuccess(response.getData());
                        } else {
                            mView.showFaild(String.valueOf(response.getErrorMsg()));
                        }
                    }
                }, new Consumer<Throwable>() {
                    @Override
                    public void accept(Throwable throwable) throws Exception {
                        mView.showFaild(throwable.getMessage());
                    }
                });

是不是清晰明了了许多呢