1.修改AndroidSubscriber可以单独不进行处理统一错误回调

keep2iron · Jun 8, 2019 · 76e741a · 76e741a
1 parent 48b5493
commit 76e741a
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/lib-pomelo/src/main/java/io/github/keep2iron/pomelo/AndroidSubscriber.kt b/lib-pomelo/src/main/java/io/github/keep2iron/pomelo/AndroidSubscriber.kt
@@ -20,6 +20,7 @@ import io.reactivex.disposables.Disposable
  * 请在application中初始化这个方法
  */
 open class AndroidSubscriber<T>(
+    private val useGlobalOnError: Boolean = true,
     private inline val onSuccess: ((resp: T) -> Unit)? = null,
     private inline val onError: ((throwable: Throwable) -> Unit)? = null
 ) : Observer<T>, Subscriber<T> {
@@ -37,7 +38,9 @@ open class AndroidSubscriber<T>(
     @CallSuper
     override fun onError(throwable: Throwable) {
         Log.e(NetworkManager.TAG, Log.getStackTraceString(throwable))
-        NetworkManager.doOnError(throwable)
+        if(useGlobalOnError) {
+            NetworkManager.doOnError(throwable)
+        }
         onError?.invoke(throwable)
     }