Browse Source

使用share代替cache

zhouhao 3 years ago
parent
commit
dd92471f63

+ 1 - 1
hsweb-logging/hsweb-access-logging-aop/src/main/java/org/hswebframework/web/logging/aop/ReactiveAopAccessLoggerSupport.java

@@ -77,7 +77,7 @@ public class ReactiveAopAccessLoggerSupport extends StaticMethodMatcherPointcutA
 
     protected Flux<?> wrapFluxResponse(Flux<?> flux, AccessLoggerInfo loggerInfo) {
 
-        Flux<?> cache = flux.cache();
+        Flux<?> cache = flux.share();
         return this
                 .currentRequestInfo()
                 .doOnNext(loggerInfo::putAccessInfo)