From b575fdc527ebcd3be984788acdc7fb3a69e7d254 Mon Sep 17 00:00:00 2001
From: renwj <renwenjie920@hotmail.com>
Date: Fri, 11 Feb 2022 20:14:21 +0800
Subject: [PATCH] =?UTF-8?q?[RxJava]=E6=B7=BB=E5=8A=A0RxJava=E5=BC=82?=
 =?UTF-8?q?=E5=B8=B8=E5=A4=84=E7=90=86=E5=99=A8=EF=BC=8C=E4=BF=AE=E6=AD=A3?=
 =?UTF-8?q?=E7=81=AB=E5=B1=B1=E5=BC=95=E6=93=8E=E8=AF=AF=E6=8A=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/mogo/commons/AbsMogoApplication.java | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/foudations/mogo-commons/src/main/java/com/mogo/commons/AbsMogoApplication.java b/foudations/mogo-commons/src/main/java/com/mogo/commons/AbsMogoApplication.java
index a46c38f046..89ebda028a 100644
--- a/foudations/mogo-commons/src/main/java/com/mogo/commons/AbsMogoApplication.java
+++ b/foudations/mogo-commons/src/main/java/com/mogo/commons/AbsMogoApplication.java
@@ -29,6 +29,9 @@ import com.mogo.eagle.core.utilcode.util.CleanUtils;
 import com.mogo.eagle.core.utilcode.util.ThreadPoolService;
 import com.mogo.eagle.core.utilcode.util.Utils;
 
+import io.reactivex.functions.Consumer;
+import io.reactivex.plugins.RxJavaPlugins;
+
 /**
  * @author congtaowang
  * @since 2019-12-23
@@ -51,6 +54,7 @@ public abstract class AbsMogoApplication extends Application {
     public void onCreate() {
         super.onCreate();
         AppStateManager.INSTANCE.init(this);
+        initRxJavaErrorHandler();
         sApp = this;
         FinalizeCrashFixer.fix();
         initARouter();
@@ -60,6 +64,12 @@ public abstract class AbsMogoApplication extends Application {
         }
     }
 
+    private void initRxJavaErrorHandler() {
+        RxJavaPlugins.setErrorHandler(throwable -> {
+            Logger.e("RxJava", throwable, null);
+        });
+    }
+
     /**
      * 初始化跨模块框架 ARouter
      */