add thread safe statement

Thomasr · Thomasr · commit a32289964b39 · 2024-08-01T13:22:39.000-04:00
diff --git a/server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/framework/filter/UserSessionPersistenceFilter.java b/server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/framework/filter/UserSessionPersistenceFilter.java
@@ -19,6 +19,7 @@
 import org.springframework.web.server.WebFilter;
 import org.springframework.web.server.WebFilterChain;
 import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
 
 import java.time.Instant;
 import java.util.Optional;
@@ -121,7 +122,8 @@ private Mono<User> refreshOauthToken(Triple<User, Connection, String> triple) {
                     oAuth2RequestContext.setAuthConfig(findAuthConfig.authConfig());
 
                     return authRequestFactory.build(oAuth2RequestContext);
-                }).flatMap(authRequest -> {
+                })
+                .publishOn(Schedulers.boundedElastic()).flatMap(authRequest -> {
                     if(authRequest == null) {
                         return Mono.just(user);
                     }
