compose线程

TransformersUitils.java

public class TransformersUitils {
    final static Observable.Transformer schedulersTransformer = new  Observable.Transformer() {
        @Override public Object call(Object observable) {
            return ((Observable)  observable).subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread());
        }
    };

    public  static  <T> Observable.Transformer<T, T> applySchedulers() {
        return (Observable.Transformer<T, T>) schedulersTransformer;
    }
}