WebSocket messaged have to be flushed

Author: Stephane Landelle

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

@@ -46,7 +46,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;
     }
 
@@ -62,7 +62,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;
     }
 
@@ -73,13 +73,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;
     }