Skip to content

Commit 50a9099

Browse files
Stephane Maldinisnicoll
Stephane Maldini
authored andcommitted
Remove unnecessary flushOnEach (since reactor-netty 0.9)
1 parent da54121 commit 50a9099

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

spring-webflux/src/main/java/org/springframework/web/reactive/socket/adapter/ReactorNettyWebSocketSession.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
import reactor.core.publisher.Mono;
2222
import reactor.netty.NettyInbound;
2323
import reactor.netty.NettyOutbound;
24-
import reactor.netty.NettyPipeline;
2524
import reactor.netty.http.websocket.WebsocketInbound;
2625
import reactor.netty.http.websocket.WebsocketOutbound;
2726

@@ -90,7 +89,6 @@ public Mono<Void> send(Publisher<WebSocketMessage> messages) {
9089
})
9190
.map(this::toFrame);
9291
return getDelegate().getOutbound()
93-
.options(NettyPipeline.SendOptions::flushOnEach)
9492
.sendObject(frames)
9593
.then();
9694
}

0 commit comments

Comments
 (0)