From 50a909908ceb00b1374a595fb139fd816d68c115 Mon Sep 17 00:00:00 2001 From: Stephane Maldini Date: Tue, 25 Jun 2019 16:05:30 -0700 Subject: [PATCH] Remove unnecessary flushOnEach (since reactor-netty 0.9) --- .../reactive/socket/adapter/ReactorNettyWebSocketSession.java | 2 -- 1 file changed, 2 deletions(-) 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(); }