// Path: app/src/main/java/com/zmj/qvod/module/bean/VideoHttpResponse.java
// public class VideoHttpResponse<T> {
// 
//     private int code;
//     private String msg;
//     T ret;
// 
//     public int getCode() {
//         return code;
//     }
// 
//     public void setCode(int code) {
//         this.code = code;
//     }
// 
//     public String getMsg() {
//         return msg;
//     }
// 
//     public void setMsg(String msg) {
//         this.msg = msg;
//     }
// 
//     public T getRet() {
//         return ret;
//     }
// 
//     public void setRet(T ret) {
//         this.ret = ret;
//     }
// }
// 
// Path: app/src/main/java/com/zmj/qvod/module/service/ApiException.java
// public class ApiException extends Exception {
//     public ApiException(String msg)
//     {
//         super(msg);
//     }
// }


import android.text.TextUtils;
import com.zmj.qvod.module.bean.VideoHttpResponse;
import com.zmj.qvod.module.service.ApiException;
import rx.Observable;
import rx.Subscriber;
import rx.android.schedulers.AndroidSchedulers;
import rx.functions.Func1;
import rx.schedulers.Schedulers;
package com.zmj.qvod.utils;




/**
 * Description: RxUtil
 * Creator: yxc
 * date: 2016/9/21 18:47
 */
public class RxUtil {

    /**
     * 统一线程处理
     *
     * @param <T>
     * @return
     */
    public static <T> Observable.Transformer<T, T> rxSchedulerHelper() {    //compose简化线程
        return new Observable.Transformer<T, T>() {
            @Override
            public Observable<T> call(Observable<T> observable) {
                return observable.subscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread());
            }
        };
    }

    /**
     * 统一返回结果处理
     *
     * @param <T>
     * @return
     */
// Path: app/src/main/java/com/zmj/qvod/module/bean/VideoHttpResponse.java
// public class VideoHttpResponse<T> {
// 
//     private int code;
//     private String msg;
//     T ret;
// 
//     public int getCode() {
//         return code;
//     }
// 
//     public void setCode(int code) {
//         this.code = code;
//     }
// 
//     public String getMsg() {
//         return msg;
//     }
// 
//     public void setMsg(String msg) {
//         this.msg = msg;
//     }
// 
//     public T getRet() {
//         return ret;
//     }
// 
//     public void setRet(T ret) {
//         this.ret = ret;
//     }
// }
// 
// Path: app/src/main/java/com/zmj/qvod/module/service/ApiException.java
// public class ApiException extends Exception {
//     public ApiException(String msg)
//     {
//         super(msg);
//     }
// }


// Path: app/src/main/java/com/zmj/qvod/utils/RxUtil.java
import android.text.TextUtils;
import com.zmj.qvod.module.bean.VideoHttpResponse;
import com.zmj.qvod.module.service.ApiException;
import rx.Observable;
import rx.Subscriber;
import rx.android.schedulers.AndroidSchedulers;
import rx.functions.Func1;
import rx.schedulers.Schedulers;

package com.zmj.qvod.utils;




/**
 * Description: RxUtil
 * Creator: yxc
 * date: 2016/9/21 18:47
 */
public class RxUtil {

    /**
     * 统一线程处理
     *
     * @param <T>
     * @return
     */
    public static <T> Observable.Transformer<T, T> rxSchedulerHelper() {    //compose简化线程
        return new Observable.Transformer<T, T>() {
            @Override
            public Observable<T> call(Observable<T> observable) {
                return observable.subscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread());
            }
        };
    }

    /**
     * 统一返回结果处理
     *
     * @param <T>
     * @return
     */
    public static <T> Observable.Transformer<VideoHttpResponse<T>, T> handleResult() {   //compose判断结果