RxJava全局异常加入日志打印

liujingxing10000 · liujingxing10000 · commit 0a55007c177f · 2019-09-26T16:05:52.000+08:00
diff --git a/app/src/main/java/com/example/httpsender/MainActivity.java b/app/src/main/java/com/example/httpsender/MainActivity.java
@@ -53,10 +53,6 @@ public void sendGet(View view) {
             .subscribe(pageList -> {
                 mBinding.tvResult.setText(new Gson().toJson(pageList));
                 //成功回调
-            }, (OnError) error -> {
-                mBinding.tvResult.setText(error.getErrorMsg());
-                //失败回调
-                error.show("发送失败,请稍后再试!");
             });
     }
 
diff --git a/rxhttp/src/main/java/rxhttp/HttpSender.java b/rxhttp/src/main/java/rxhttp/HttpSender.java
@@ -40,13 +40,12 @@ public final class HttpSender {
     static {
         Consumer<? super Throwable> errorHandler = RxJavaPlugins.getErrorHandler();
         if (errorHandler == null) {
-            RxJavaPlugins.setErrorHandler(throwable -> {
-                /*
-                RxJava2的一个重要的设计理念是：不吃掉任何一个异常, 即抛出的异常无人处理，便会导致程序崩溃
-                这就会导致一个问题，当RxJava2“downStream”取消订阅后，“upStream”仍有可能抛出异常，
-                这时由于已经取消订阅，“downStream”无法处理异常，此时的异常无人处理，便会导致程序崩溃
-                */
-            });
+            /*
+            RxJava2的一个重要的设计理念是：不吃掉任何一个异常, 即抛出的异常无人处理，便会导致程序崩溃
+            这就会导致一个问题，当RxJava2“downStream”取消订阅后，“upStream”仍有可能抛出异常，
+            这时由于已经取消订阅，“downStream”无法处理异常，此时的异常无人处理，便会导致程序崩溃
+            */
+            RxJavaPlugins.setErrorHandler(LogUtil::log);
         }
     }
 
diff --git a/rxhttp/src/main/java/rxhttp/wrapper/utils/LogUtil.java b/rxhttp/src/main/java/rxhttp/wrapper/utils/LogUtil.java
@@ -19,13 +19,20 @@
 public class LogUtil {
 
     private static final String TAG = "RxHttp";
+    private static final String TAG_RXJAVA = "RxJava";
 
     private static boolean isDebug = false;
 
     public static void setDebug(boolean debug) {
         isDebug = debug;
     }
 
+    //打印Http请求连接失败异常日志
+    public static void log(Throwable throwable) {
+        if (!isDebug) return;
+        Log.e(TAG_RXJAVA, throwable.toString());
+    }
+
     //打印Http请求连接失败异常日志
     public static void log(@NonNull String url, Throwable throwable) {
         if (!isDebug) return;
