lywsvip/hsweb-framework
1
0
Fork 0
mirror of https://github.com/hs-web/hsweb-framework.git synced 2026-09-03 06:35:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: 修复AsyncEventHooks可能导致异步操作不执行问题. (#240)

Browse Source
This commit is contained in:
老周
2023-09-14 03:43:26 -05:00
committed by GitHub
parent 3c494aa0ca
commit 51c42c687f
1 changed files with 6 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
hsweb-core/src/main/java/org/hswebframework/web/event/AsyncEventHooks.java
View File

@@ -26,12 +26,10 @@ public class AsyncEventHooks {
if (hooksList == null) {
return publisher;
}
if (hooksList.size() == 1) {
return hooksList.getFirst().hookFirst(event, publisher);
for (AsyncEventHook asyncEventHook : hooksList) {
publisher = asyncEventHook.hookFirst(event, publisher);
}
return Flux.fromIterable(hooksList)
.flatMap(hook -> hook.hookFirst(event, publisher))
.then();
return publisher;
}
static Mono<?> hookAsync(AsyncEvent event, Mono<?> publisher) {
@@ -39,12 +37,10 @@ public class AsyncEventHooks {
if (hooksList == null) {
return publisher;
}
if (hooksList.size() == 1) {
return hooksList.getFirst().hookAsync(event, publisher);
for (AsyncEventHook asyncEventHook : hooksList) {
publisher = asyncEventHook.hookAsync(event, publisher);
}
return Flux.fromIterable(hooksList)
.flatMap(hook -> hook.hookAsync(event, publisher))
.then();
return publisher;
}