From 1ee869a72d68d7b6b2124bd7febb550f9387bb67 Mon Sep 17 00:00:00 2001
From: godotg <jaysunxiao@gmail.com>
Date: Sun, 14 Apr 2024 20:25:41 +0800
Subject: [PATCH] perf[event]: function style handler

---
 .../main/java/com/zfoo/event/manager/EventBus.java   | 12 ++++--------
 1 file changed, 4 insertions(+), 8 deletions(-)

diff --git a/event/src/main/java/com/zfoo/event/manager/EventBus.java b/event/src/main/java/com/zfoo/event/manager/EventBus.java
index 3da9f45f..c68ad384 100644
--- a/event/src/main/java/com/zfoo/event/manager/EventBus.java
+++ b/event/src/main/java/com/zfoo/event/manager/EventBus.java
@@ -59,8 +59,8 @@ public abstract class EventBus {
     /**
      * event exception handler
      */
-    public static BiConsumer<IEventReceiver, IEvent> exceptionHandler = null;
-    public static Consumer<IEvent> noEventReceiverHandler = null;
+    public static BiConsumer<IEventReceiver, IEvent> exceptionFunction = (receiver, event) -> {};
+    public static Consumer<IEvent> noReceiverFunction = event -> {};
 
     static {
         for (int i = 0; i < executors.length; i++) {
@@ -106,9 +106,7 @@ public abstract class EventBus {
         var clazz = event.getClass();
         var receivers = receiverMap.get(clazz);
         if (CollectionUtils.isEmpty(receivers)) {
-            if (noEventReceiverHandler != null) {
-                noEventReceiverHandler.accept(event);
-            }
+            noReceiverFunction.accept(event);
             return;
         }
         for (var receiver : receivers) {
@@ -125,9 +123,7 @@ public abstract class EventBus {
             receiver.invoke(event);
         } catch (Throwable t) {
             logger.error("eventBus {} [{}] unknown error", receiver.bus(), event.getClass().getSimpleName(), t);
-            if (exceptionHandler != null) {
-                exceptionHandler.accept(receiver, event);
-            }
+            exceptionFunction.accept(receiver, event);
         }
     }