Android RxJava 将subscribeOn与observeOn简化合并

import ;
import ;
import ;

/**
 * @author AcmenXD
 * @version v1.0
 * @github /AcmenXD
 * @date 2017/3/21 14:55
 * @detail Rx工具类
 */
public class RxUtils {
    private final static  schedulersTransformer = new () {
        @Override
        public Object call(Object observable) {
            return ((Observable) observable)
                    .subscribeOn(())
                    .observeOn(());
        }
    };

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

/**
 * 用法示例
 */
("1","2")
    .compose(RxUtils.<String>applySchedulers())
    //上面一行代码,等同于下面的这两行代码
    //.subscribeOn(())
    //.observeOn(())
    .subscribe(new Action1<String>() {
        @Override
        public void call(String pS) {

        }
    });