FastObserver增加 FastNullException错误判断用于处理部分特殊情况

Author: AriesHoo

app/src/main/java/com/aries/library/fast/demo/base/BaseEntity.java

@@ -1,11 +1,14 @@
 package com.aries.library.fast.demo.base;
 
 /**
- * Created: AriesHoo on 2017/6/29 16:39
- * Function:
- * Desc:
+ * @Author: AriesHoo on 2019/7/11 22:00
+ * @E-Mail: AriesHoo@126.com
+ * @Function:
+ * @Description:
  */
 public class BaseEntity<T> {
+
+    public boolean success;
     public int code;
     public String msg;
     public T data;

app/src/main/java/com/aries/library/fast/demo/retrofit/repository/BaseRepository.java

@@ -3,6 +3,7 @@
 import android.accounts.NetworkErrorException;
 
 import com.aries.library.fast.demo.base.BaseEntity;
+import com.aries.library.fast.retrofit.FastNullException;
 import com.aries.library.fast.retrofit.FastRetryWhen;
 import com.aries.library.fast.retrofit.FastTransformer;
 
@@ -30,7 +31,12 @@ protected <T> Observable<T> transform(Observable<BaseEntity<T>> observable) {
                             if (result == null) {
                                 return Observable.error(new NetworkErrorException());
                             } else {
-                                return Observable.just(result.data);
+                                if (result.success) {
+                                    return result.data != null ? Observable.just(result.data)
+                                            : Observable.error(new FastNullException());
+                                } else {
+                                    return Observable.error(new NetworkErrorException());
+                                }
                             }
                         }));
     }

library/src/main/java/com/aries/library/fast/retrofit/FastNullException.java

@@ -0,0 +1,22 @@
+package com.aries.library.fast.retrofit;
+
+/**
+ * @Author: AriesHoo on 2019/7/11 21:55
+ * @E-Mail: AriesHoo@126.com
+ * @Function:  特定空对象Exception 用于解决接口某些情况下数据null无法回调{@link FastObserver#_onNext(Object)}的情况
+ * @Description:
+ */
+public class FastNullException extends Exception {
+
+    public FastNullException(String message) {
+        super(message);
+    }
+
+    public FastNullException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    public FastNullException(Throwable cause) {
+        super(cause);
+    }
+}

library/src/main/java/com/aries/library/fast/retrofit/FastObserver.java

@@ -34,6 +34,10 @@ public void onComplete() {
 
     @Override
     public void onError(Throwable e) {
+        if (e instanceof FastNullException) {
+            _onNext(null);
+            return;
+        }
         if (FastManager.getInstance().getHttpRequestControl() != null) {
             FastManager.getInstance().getHttpRequestControl().httpRequestError(mHttpRequestControl, e);
         }