Merge branch 'master' into page

nilupeng

2022-08-09 92f09807eeb57f0cb9a4686cde38834549b34962

 app/src/main/java/com/runt/open/mvvm/base/model/BaseViewModel.java

@@ -2,10 +2,14 @@

import androidx.lifecycle.ViewModel;

import com.runt.open.mvvm.retrofit.observable.HttpObserver;
import com.runt.open.mvvm.base.activities.BaseActivity;
import com.runt.open.mvvm.retrofit.AndroidScheduler;
import com.runt.open.mvvm.retrofit.api.CommonApiCenter;
import com.runt.open.mvvm.retrofit.observable.HttpObserver;
import com.runt.open.mvvm.retrofit.utils.RetrofitUtils;

import io.reactivex.Observable;
import io.reactivex.functions.Consumer;
import io.reactivex.schedulers.Schedulers;

/**
@@ -13,6 +17,12 @@
 */
public class BaseViewModel extends ViewModel {

    protected BaseActivity mActivity;
    protected CommonApiCenter commonApi = RetrofitUtils.getInstance().getCommonApi();

    public void onCreate(BaseActivity activity) {
        this.mActivity = activity;
    }

    /**
     * 网络请求观察
@@ -27,5 +37,30 @@
    }


    /**
     * 网络请求观察
     * @param observable
     * @param <T>
     * @return
     */
    public <T> void httpObserverOnLoading(Observable<T> observable, HttpObserver observer){
        observable.subscribeOn(Schedulers.io())//指定网络请求在io后台线程中进行
                .doOnSubscribe(disposable -> {
                    mActivity.showLoadingDialog("");
                })
                .observeOn(AndroidScheduler.mainThread())
                .doOnError(new Consumer<Throwable>() {
                    @Override
                    public void accept(Throwable throwable) throws Exception {

                    }
                })
                .doOnComplete(() -> {
                    mActivity.dissmissLoadingDialog();
                })
                .subscribe(observer);
    }



}