mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-09-04 04:18:21 +00:00
feat[event]: support virtual thread api
This commit is contained in:
@@ -39,12 +39,12 @@ public class EventReceiverDefinition implements IEventReceiver {
|
||||
// 事件接收方式
|
||||
private Bus bus;
|
||||
|
||||
public EventReceiverDefinition(Object bean, Method method, Class<? extends IEvent> eventClazz, Bus bus) {
|
||||
public EventReceiverDefinition(Object bean, Method method, Bus bus, Class<? extends IEvent> eventClazz) {
|
||||
this.bean = bean;
|
||||
this.method = method;
|
||||
this.bus = bus;
|
||||
this.eventClazz = eventClazz;
|
||||
ReflectionUtils.makeAccessible(this.method);
|
||||
this.bus = bus;
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -80,7 +80,7 @@ public class EventRegisterProcessor implements BeanPostProcessor {
|
||||
}
|
||||
|
||||
var bus = method.getDeclaredAnnotation(EventReceiver.class).value();
|
||||
var receiverDefinition = new EventReceiverDefinition(bean, method, eventClazz, bus);
|
||||
var receiverDefinition = new EventReceiverDefinition(bean, method, bus, eventClazz);
|
||||
var enhanceReceiverDefinition = EnhanceUtils.createEventReceiver(receiverDefinition);
|
||||
|
||||
// key:class类型 value:观察者 注册Event的receiverMap中
|
||||
|
||||
Reference in New Issue
Block a user