LiEventBus增加自定义push

leaderli · Oct 20, 2024 · 23534d5 · 23534d5
1 parent 4152ffb
commit 23534d5
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 8 deletions.
diff --git a/litool-core/src/main/java/io/leaderli/litool/core/event/LiEventBus.java b/litool-core/src/main/java/io/leaderli/litool/core/event/LiEventBus.java
@@ -84,17 +84,23 @@ private static class DefaultBiConsumer<E extends LiEventObject<S>, S> implements
         @Override
         public void accept(SourceProvider<S> sourceProvider, ILiEventListener<E, S> listener) {
             S source = sourceProvider.source;
-            if (source == null) {
-                listener.onNull();
-                return;
-            }
             try {
+                if (source == null) {
+                    listener.onNull();
+                    return;
+                }
                 if (listener.before(source)) {
                     listener.listen(source);
                     listener.after(sourceProvider.liEventBusBehavior);
                 }
             } catch (Throwable throwable) {
-                listener.onError(throwable);
+
+                try {
+
+                    listener.onError(throwable);
+                } catch (Throwable ignore) {
+                    //
+                }
             }
         }
     }

diff --git a/litool-core/src/test/java/io/leaderli/litool/core/event/LiEventBusTest.java b/litool-core/src/test/java/io/leaderli/litool/core/event/LiEventBusTest.java
@@ -35,10 +35,8 @@ void getPublisher() {
         });
         eventBus.registerListener(new TestLiEventListener3());
 
-        Assertions.assertThrows(RuntimeException.class, () -> {
+        Assertions.assertDoesNotThrow(() -> {
             eventBus.push(new TestStringLiEventObject("456"));
-            Assertions.fail();
-            eventBus.push(new TestStringLiEventObject(null));
         });
     }