diff --git a/hsweb-core/src/main/java/org/hswebframework/web/event/DefaultAsyncEvent.java b/hsweb-core/src/main/java/org/hswebframework/web/event/DefaultAsyncEvent.java index 045c54c02..36f30afb9 100644 --- a/hsweb-core/src/main/java/org/hswebframework/web/event/DefaultAsyncEvent.java +++ b/hsweb-core/src/main/java/org/hswebframework/web/event/DefaultAsyncEvent.java @@ -10,7 +10,10 @@ public class DefaultAsyncEvent implements AsyncEvent { @Getter private Mono async = Mono.empty(); + private boolean hasListener; + public synchronized void async(Publisher publisher) { + hasListener = true; this.async = async.then(Mono.from(publisher).then()); } @@ -21,4 +24,8 @@ public class DefaultAsyncEvent implements AsyncEvent { return this.async; } + + public boolean hasListener() { + return hasListener; + } }