tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-05-26 01:59:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf[event]: function style handler

Browse Source
This commit is contained in:
godotg
2024-04-14 20:25:41 +08:00
parent 76c20ff026
commit 1ee869a72d
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
event/src/main/java/com/zfoo/event/manager/EventBus.java
+4 -8
View File
@@ -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);
}
}