// Path: app/src/main/java/com/github/bigexcalibur/herovideo/mvp/common/view/IRxBaseView.java
// public interface IRxBaseView {
// 
//     void loadData();
// 
//     void FinishLoadData();
// 
//     void onNodata();
// 
//     void onNetDisConnected();
// 
//     void onGlobalThemeChange();
// 
//     void onSpecificThemeChange(View view);
// 
//     void finishTask();
// }
// 
// Path: app/src/main/java/com/github/bigexcalibur/herovideo/rxbus/RxBus.java
// public class RxBus
// {
// 
//     private static volatile RxBus mInstance;
// 
//     private final Subject<Object,Object> bus;
// 
// 
//     private RxBus()
//     {
// 
//         bus = new SerializedSubject<>(PublishSubject.create());
//     }
// 
//     /**
//      * 单例模式RxBus2
//      *
//      * @return
//      */
//     public static RxBus getInstance()
//     {
// 
//         RxBus rxBus = mInstance;
//         if (mInstance == null)
//         {
//             synchronized (RxBus.class)
//             {
//                 rxBus = mInstance;
//                 if (mInstance == null)
//                 {
//                     rxBus = new RxBus();
//                     mInstance = rxBus;
//                 }
//             }
//         }
// 
//         return rxBus;
//     }
// 
// 
//     /**
//      * 发送消息
//      *
//      * @param object
//      */
//     public void post(Object object)
//     {
// 
//         bus.onNext(object);
//     }
// 
//     /**
//      * 接收消息
//      *
//      * @param eventType
//      * @param <T>
//      * @return
//      */
//     public <T> Observable<T> toObserverable(Class<T> eventType)
//     {
// 
//         return bus.ofType(eventType);
//     }
// }
// 
// Path: app/src/main/java/com/github/bigexcalibur/herovideo/rxbus/event/ThemeChangeEvent.java
// public class ThemeChangeEvent {
//     /**
//      *  主题变化的事件
//      */
//     public static final int INIT_CHANGE = 1;
//     public static final int GLOBLE_CHANGE = 2;
//     public static final int SPECIFIC_CHANGE =3;
// 
// 
//     public int eventType;
//     public View view;
// 
//     public ThemeChangeEvent(int eventType){
//         this.eventType =eventType;
//     }
// 
//     public ThemeChangeEvent(int eventType ,View view){
//         this.eventType = eventType;
//         this.view = view;
//     }
// 
// }


import android.view.View;
import com.github.bigexcalibur.herovideo.mvp.common.view.IRxBaseView;
import com.github.bigexcalibur.herovideo.rxbus.RxBus;
import com.github.bigexcalibur.herovideo.rxbus.event.ThemeChangeEvent;
import rx.Subscription;
package com.github.bigexcalibur.herovideo.mvp.common.presenter;




/**
 * Created by Xie.Zhou on 2017/1/18.
 */

public class RxBaseViewPresenter {
    private IRxBaseView mIRxBaseView;
    private Subscription mThemeChangeSubscription;

    protected RxBaseViewPresenter(){
    }

    public RxBaseViewPresenter(IRxBaseView IRxBaseView) {
        this.mIRxBaseView = IRxBaseView;
    }

    public void onInitThemeChange() {
        // 发送MagicaSacura初始化的事件
        RxBus.getInstance().post(new ThemeChangeEvent(ThemeChangeEvent.INIT_CHANGE));
    }

    public void onGlobalThemeChange() {
// Path: app/src/main/java/com/github/bigexcalibur/herovideo/mvp/common/view/IRxBaseView.java
// public interface IRxBaseView {
// 
//     void loadData();
// 
//     void FinishLoadData();
// 
//     void onNodata();
// 
//     void onNetDisConnected();
// 
//     void onGlobalThemeChange();
// 
//     void onSpecificThemeChange(View view);
// 
//     void finishTask();
// }
// 
// Path: app/src/main/java/com/github/bigexcalibur/herovideo/rxbus/RxBus.java
// public class RxBus
// {
// 
//     private static volatile RxBus mInstance;
// 
//     private final Subject<Object,Object> bus;
// 
// 
//     private RxBus()
//     {
// 
//         bus = new SerializedSubject<>(PublishSubject.create());
//     }
// 
//     /**
//      * 单例模式RxBus2
//      *
//      * @return
//      */
//     public static RxBus getInstance()
//     {
// 
//         RxBus rxBus = mInstance;
//         if (mInstance == null)
//         {
//             synchronized (RxBus.class)
//             {
//                 rxBus = mInstance;
//                 if (mInstance == null)
//                 {
//                     rxBus = new RxBus();
//                     mInstance = rxBus;
//                 }
//             }
//         }
// 
//         return rxBus;
//     }
// 
// 
//     /**
//      * 发送消息
//      *
//      * @param object
//      */
//     public void post(Object object)
//     {
// 
//         bus.onNext(object);
//     }
// 
//     /**
//      * 接收消息
//      *
//      * @param eventType
//      * @param <T>
//      * @return
//      */
//     public <T> Observable<T> toObserverable(Class<T> eventType)
//     {
// 
//         return bus.ofType(eventType);
//     }
// }
// 
// Path: app/src/main/java/com/github/bigexcalibur/herovideo/rxbus/event/ThemeChangeEvent.java
// public class ThemeChangeEvent {
//     /**
//      *  主题变化的事件
//      */
//     public static final int INIT_CHANGE = 1;
//     public static final int GLOBLE_CHANGE = 2;
//     public static final int SPECIFIC_CHANGE =3;
// 
// 
//     public int eventType;
//     public View view;
// 
//     public ThemeChangeEvent(int eventType){
//         this.eventType =eventType;
//     }
// 
//     public ThemeChangeEvent(int eventType ,View view){
//         this.eventType = eventType;
//         this.view = view;
//     }
// 
// }


// Path: app/src/main/java/com/github/bigexcalibur/herovideo/mvp/common/presenter/RxBaseViewPresenter.java
import android.view.View;
import com.github.bigexcalibur.herovideo.mvp.common.view.IRxBaseView;
import com.github.bigexcalibur.herovideo.rxbus.RxBus;
import com.github.bigexcalibur.herovideo.rxbus.event.ThemeChangeEvent;
import rx.Subscription;

package com.github.bigexcalibur.herovideo.mvp.common.presenter;




/**
 * Created by Xie.Zhou on 2017/1/18.
 */

public class RxBaseViewPresenter {
    private IRxBaseView mIRxBaseView;
    private Subscription mThemeChangeSubscription;

    protected RxBaseViewPresenter(){
    }

    public RxBaseViewPresenter(IRxBaseView IRxBaseView) {
        this.mIRxBaseView = IRxBaseView;
    }

    public void onInitThemeChange() {
        // 发送MagicaSacura初始化的事件
        RxBus.getInstance().post(new ThemeChangeEvent(ThemeChangeEvent.INIT_CHANGE));
    }

    public void onGlobalThemeChange() {
        RxBus.getInstance().post(new ThemeChangeEvent(ThemeChangeEvent.GLOBLE_CHANGE));