Fix broken Mono chain

tt4g · jzheaux · commit 65f788532e1d · 2020-09-16T09:53:23.000-06:00
This commit restore broken Mono chain in WebSessionServerCsrfTokenRepository.generateToken(ServerWebExchange). Closes gh-9017
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
@@ -52,8 +52,7 @@ public class WebSessionServerCsrfTokenRepository implements ServerCsrfTokenRepos
 
 	@Override
 	public Mono<CsrfToken> generateToken(ServerWebExchange exchange) {
-		Mono.just(exchange).publishOn(Schedulers.boundedElastic());
-		return Mono.fromCallable(() -> createCsrfToken());
+		return Mono.fromCallable(() -> createCsrfToken()).subscribeOn(Schedulers.boundedElastic());
 	}
 
 	@Override

Original file line number	Diff line number	Diff line change
`@@ -52,8 +52,7 @@ public class WebSessionServerCsrfTokenRepository implements ServerCsrfTokenRepos`
`52`	`52`
`53`	`53`	`@Override`
`54`	`54`	`public Mono<CsrfToken> generateToken(ServerWebExchange exchange) {`
`55`		`- Mono.just(exchange).publishOn(Schedulers.boundedElastic());`
`56`		`- return Mono.fromCallable(() -> createCsrfToken());`
	`55`	`+ return Mono.fromCallable(() -> createCsrfToken()).subscribeOn(Schedulers.boundedElastic());`
`57`	`56`	`}`
`58`	`57`
`59`	`58`	`@Override`