diff --git a/hsweb-system/hsweb-system-authorization/hsweb-system-authorization-default/src/main/java/org/hswebframework/web/system/authorization/defaults/service/DefaultReactiveAuthenticationManager.java b/hsweb-system/hsweb-system-authorization/hsweb-system-authorization-default/src/main/java/org/hswebframework/web/system/authorization/defaults/service/DefaultReactiveAuthenticationManager.java index bffa38393..20f134621 100644 --- a/hsweb-system/hsweb-system-authorization/hsweb-system-authorization-default/src/main/java/org/hswebframework/web/system/authorization/defaults/service/DefaultReactiveAuthenticationManager.java +++ b/hsweb-system/hsweb-system-authorization/hsweb-system-authorization-default/src/main/java/org/hswebframework/web/system/authorization/defaults/service/DefaultReactiveAuthenticationManager.java @@ -46,7 +46,7 @@ public class DefaultReactiveAuthenticationManager implements ReactiveAuthenticat .doOnSuccess(__ -> log.info("clear user {} authentication cache success", event.getUserId())); } if (event.isAsync()) { - event.async(operator); + event.first(operator); } else { log.warn("please use async for ClearUserAuthorizationCacheEvent"); operator.subscribe();