From 0c89bf11bcddd39b5193bb19e28399648c59a2b8 Mon Sep 17 00:00:00 2001
From: nilupeng <qingingrunt2010@qq.com>
Date: Sat, 29 Jan 2022 11:04:25 +0000
Subject: [PATCH] 登录界面及接口
---
app/src/main/java/com/runt/open/mvvm/base/model/BaseViewModel.java | 28 +++++++++++++++++++++++++++-
1 files changed, 27 insertions(+), 1 deletions(-)
diff --git a/app/src/main/java/com/runt/open/mvvm/base/model/BaseViewModel.java b/app/src/main/java/com/runt/open/mvvm/base/model/BaseViewModel.java
index a50ff27..3c172a9 100644
--- a/app/src/main/java/com/runt/open/mvvm/base/model/BaseViewModel.java
+++ b/app/src/main/java/com/runt/open/mvvm/base/model/BaseViewModel.java
@@ -1,9 +1,11 @@
package com.runt.open.mvvm.base.model;
+import androidx.lifecycle.MutableLiveData;
import androidx.lifecycle.ViewModel;
-import com.runt.open.mvvm.retrofit.observable.HttpObserver;
+import com.runt.open.mvvm.data.LoadingCmd;
import com.runt.open.mvvm.retrofit.AndroidScheduler;
+import com.runt.open.mvvm.retrofit.observable.HttpObserver;
import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;
@@ -13,6 +15,11 @@
*/
public class BaseViewModel extends ViewModel {
+ MutableLiveData<LoadingCmd> loadLive = new MutableLiveData<>();
+
+ public MutableLiveData<LoadingCmd> getLoadLive() {
+ return loadLive;
+ }
/**
* 网络请求观察
@@ -27,5 +34,24 @@
}
+ /**
+ * 网络请求观察
+ * @param observable
+ * @param <T>
+ * @return
+ */
+ public <T> void httpObserverOnLoading(Observable<T> observable, HttpObserver observer){
+ observable.subscribeOn(Schedulers.io())//指定网络请求在io后台线程中进行
+ .doOnSubscribe(disposable -> {
+ loadLive.setValue(new LoadingCmd(LoadingCmd.CMD.LOADING,"请求数据中..."));
+ })
+ .observeOn(AndroidScheduler.mainThread())
+ .doOnComplete(() -> {
+ loadLive.postValue(new LoadingCmd(LoadingCmd.CMD.DISSMISS));
+ })
+ .subscribe(observer);
+ }
+
+
}
--
Gitblit v1.9.1