From 89e35a1933ba40513a96572b27291c0aa65c918c Mon Sep 17 00:00:00 2001
From: Runt <qingingrunt2010@qq.com>
Date: Sat, 11 Oct 2025 10:21:42 +0000
Subject: [PATCH] 框架优化
---
libmvi/src/main/java/com/runt/open/mvi/retrofit/observable/HttpObserver.java | 30 +++++++++++++++---------------
1 files changed, 15 insertions(+), 15 deletions(-)
diff --git a/libmvi/src/main/java/com/runt/open/mvi/retrofit/observable/HttpObserver.java b/libmvi/src/main/java/com/runt/open/mvi/retrofit/observable/HttpObserver.java
index 659c3cf..7695b29 100644
--- a/libmvi/src/main/java/com/runt/open/mvi/retrofit/observable/HttpObserver.java
+++ b/libmvi/src/main/java/com/runt/open/mvi/retrofit/observable/HttpObserver.java
@@ -3,7 +3,6 @@
import android.util.Log;
import com.google.gson.Gson;
-import com.runt.open.mvi.base.BaseActivity;
import com.runt.open.mvi.data.HttpApiResult;
import java.net.ConnectException;
@@ -22,27 +21,24 @@
*/
public abstract class HttpObserver<RESULT> implements Observer<HttpApiResult<RESULT>> {
- BaseActivity activity;
-
public HttpObserver() {
}
- public HttpObserver(BaseActivity activity) {
- this.activity = activity;
- }
-
final String TAG = "HttpObserver";
+ protected int observerStatus;//0 订阅 1 响应 2 请求错误 3 结束
@Override
public void onSubscribe(Disposable d) {
+ observerStatus = 0 ;
Log.d(TAG,"onSubscribe "+hashCode());
}
@Override
public void onNext(HttpApiResult<RESULT> httpResult) {
+ observerStatus = 1;
Log.d(TAG,"onNext "+httpResult);
if (httpResult != null && httpResult.code == 0) {
- onSuccess(httpResult.data);
+ handleResult(httpResult.data);
}else{
onFailed(httpResult);//接口返回错误
}
@@ -50,6 +46,7 @@
@Override
public void onError(Throwable e) {
+ observerStatus = 2;
Log.e(TAG,"onError "+e.getMessage()+" "+hashCode());
int code = 600;
String msg = "网络请求失败，请检查网络或稍后重试";
@@ -70,16 +67,19 @@
@Override
public void onComplete() {
+ observerStatus = 3;
Log.i(TAG,"onComplete "+hashCode());
}
- protected abstract void onSuccess(RESULT data);
+ /**
+ * 处理返回数据
+ * @param result
+ */
+ public abstract void handleResult(RESULT result);
- protected void onFailed(HttpApiResult error){
- Log.i(TAG,"onFailed "+activity);
- if(activity != null){
- activity.showToast(error.msg);
- }
- }
+ /**
+ * 请求错误信息
+ */
+ public abstract void onFailed(HttpApiResult<RESULT> result);
}
--
Gitblit v1.9.1