Regression: writeAndFlush

Author: Stephane Landelle

providers/netty/src/main/java/org/asynchttpclient/providers/netty/ws/NettyWebSocket.java

@@ -65,7 +65,7 @@ public NettyWebSocket(Channel channel, Collection<WebSocketListener> listeners)
 
     @Override
     public WebSocket sendMessage(byte[] message) {
-        channel.write(new BinaryWebSocketFrame(wrappedBuffer(message)));
+        channel.writeAndFlush(new BinaryWebSocketFrame(wrappedBuffer(message)));
         return this;
     }
 
@@ -81,7 +81,7 @@ public WebSocket stream(byte[] fragment, int offset, int len, boolean last) {
 
     @Override
     public WebSocket sendTextMessage(String message) {
-        channel.write(new TextWebSocketFrame(message));
+        channel.writeAndFlush(new TextWebSocketFrame(message));
         return this;
     }
 
@@ -92,13 +92,13 @@ public WebSocket streamText(String fragment, boolean last) {
 
     @Override
     public WebSocket sendPing(byte[] payload) {
-        channel.write(new PingWebSocketFrame(wrappedBuffer(payload)));
+        channel.writeAndFlush(new PingWebSocketFrame(wrappedBuffer(payload)));
         return this;
     }
 
     @Override
     public WebSocket sendPong(byte[] payload) {
-        channel.write(new PongWebSocketFrame(wrappedBuffer(payload)));
+        channel.writeAndFlush(new PongWebSocketFrame(wrappedBuffer(payload)));
         return this;
     }
 
@@ -120,7 +120,7 @@ public void close() {
         if (channel.isOpen()) {
             onClose();
             listeners.clear();
-            channel.write(new CloseWebSocketFrame()).addListener(ChannelFutureListener.CLOSE);
+            channel.writeAndFlush(new CloseWebSocketFrame()).addListener(ChannelFutureListener.CLOSE);
         }
     }