From f58a262eb42625f7c37cb348479c76fe25017a92 Mon Sep 17 00:00:00 2001 From: Rob Winch Date: Mon, 18 May 2020 11:10:01 -0500 Subject: [PATCH] Revert "Create the CSRF token on the bounded elactic scheduler" Reactor did not add bounded elastic until a later version. This reverts commit c0154f2315a40e36b1c319b74c91a9953c9dfe34. --- .../web/server/csrf/WebSessionServerCsrfTokenRepository.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/web/src/main/java/org/springframework/security/web/server/csrf/WebSessionServerCsrfTokenRepository.java b/web/src/main/java/org/springframework/security/web/server/csrf/WebSessionServerCsrfTokenRepository.java index e09512c0e2..8680da5863 100644 --- a/web/src/main/java/org/springframework/security/web/server/csrf/WebSessionServerCsrfTokenRepository.java +++ b/web/src/main/java/org/springframework/security/web/server/csrf/WebSessionServerCsrfTokenRepository.java @@ -18,7 +18,6 @@ package org.springframework.security.web.server.csrf; import org.springframework.util.Assert; import org.springframework.web.server.ServerWebExchange; import reactor.core.publisher.Mono; -import reactor.core.scheduler.Schedulers; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpSession; @@ -49,9 +48,7 @@ public class WebSessionServerCsrfTokenRepository @Override public Mono generateToken(ServerWebExchange exchange) { - return Mono.just(exchange) - .publishOn(Schedulers.boundedElastic()) - .fromCallable(() -> createCsrfToken()); + return Mono.fromCallable(() -> createCsrfToken()); } @Override