nilupeng
2022-08-09 58a4a54c62c65cab92c85fd3edeff832e4572ead
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);
    }
}