diff --git a/spring-web/src/main/java/org/springframework/http/codec/ServerSentEventHttpMessageWriter.java b/spring-web/src/main/java/org/springframework/http/codec/ServerSentEventHttpMessageWriter.java index 2568ad11f27..ceeabd75e7b 100644 --- a/spring-web/src/main/java/org/springframework/http/codec/ServerSentEventHttpMessageWriter.java +++ b/spring-web/src/main/java/org/springframework/http/codec/ServerSentEventHttpMessageWriter.java @@ -79,10 +79,6 @@ public class ServerSentEventHttpMessageWriter implements HttpMessageWriter> body = encode(inputStream, bufferFactory, type); - // Keep the SSE connection open even for cold stream in order to avoid - // unexpected browser reconnection - body = body.concatWith(Flux.never()); - return outputMessage.writeAndFlushWith(body); }