fix: wrapped throwable function in a try catch

DevCycleHQ · Nov 12, 2024 · 77952f2 · 77952f2
1 parent 5c31040
commit 77952f2
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/android-client-sdk/src/main/java/com/devcycle/sdk/android/eventsource/EventSource.java b/android-client-sdk/src/main/java/com/devcycle/sdk/android/eventsource/EventSource.java
@@ -277,7 +277,12 @@ public boolean awaitClosed(final long timeout) throws InterruptedException {
 
   private void closeCurrentStream(ReadyState previousState) {
     if (previousState == ReadyState.OPEN) {
-      handler.onClosed();
+      try {
+        handler.onClosed();
+      } catch (Exception e) {
+        DevCycleLogger.w("Message handler threw an exception: " + e.toString());
+        handler.onError(e);
+      }
     }
 
     if (call != null) {