diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/socket/adapter/ReactorNettyWebSocketSession.java b/spring-webflux/src/main/java/org/springframework/web/reactive/socket/adapter/ReactorNettyWebSocketSession.java index c0f571c56e..23376edbec 100644 --- a/spring-webflux/src/main/java/org/springframework/web/reactive/socket/adapter/ReactorNettyWebSocketSession.java +++ b/spring-webflux/src/main/java/org/springframework/web/reactive/socket/adapter/ReactorNettyWebSocketSession.java @@ -21,7 +21,6 @@ import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import reactor.netty.NettyInbound; import reactor.netty.NettyOutbound; -import reactor.netty.NettyPipeline; import reactor.netty.http.websocket.WebsocketInbound; import reactor.netty.http.websocket.WebsocketOutbound; @@ -90,7 +89,6 @@ public class ReactorNettyWebSocketSession }) .map(this::toFrame); return getDelegate().getOutbound() - .options(NettyPipeline.SendOptions::flushOnEach) .sendObject(frames) .then(); }