From b2d9e7c28ddb7f122b402722bca94c2aabdb56df Mon Sep 17 00:00:00 2001 From: Stephane Maldini Date: Mon, 2 May 2016 22:56:18 +0100 Subject: [PATCH] Split FluxProcessor factories into individual Processor, remove confusing factories --- .../web/server/adapter/DefaultServerWebExchange.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java b/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java index 8e9807491c..295db4f880 100644 --- a/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java +++ b/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java @@ -19,8 +19,6 @@ import java.util.Map; import java.util.Optional; import java.util.concurrent.ConcurrentHashMap; -import reactor.core.publisher.EmitterProcessor; -import reactor.core.publisher.FluxProcessor; import reactor.core.publisher.Mono; import org.springframework.http.server.reactive.ServerHttpRequest; @@ -89,8 +87,7 @@ public class DefaultServerWebExchange implements ServerWebExchange { if (this.sessionMono == null) { synchronized (this.createSessionLock) { if (this.sessionMono == null) { - FluxProcessor replay = EmitterProcessor.replay(1); - this.sessionMono = this.sessionManager.getSession(this).subscribeWith(replay).next(); + this.sessionMono = this.sessionManager.getSession(this).cache(); } } }