Netty websocket streaming, close AsyncHttpClient#518

Author: Stephane Landelle

src/main/java/com/ning/http/client/providers/netty/ws/NettyWebSocket.java

@@ -72,12 +72,18 @@ public WebSocket sendMessage(byte[] message) {
 
     @Override
     public WebSocket stream(byte[] fragment, boolean last) {
-        throw new UnsupportedOperationException("Streaming currently only supported by the Grizzly provider.");
+        BinaryWebSocketFrame frame = new BinaryWebSocketFrame(wrappedBuffer(fragment));
+        frame.setFinalFragment(last);
+        channel.write(frame);
+        return this;
     }
 
     @Override
     public WebSocket stream(byte[] fragment, int offset, int len, boolean last) {
-        throw new UnsupportedOperationException("Streaming currently only supported by the Grizzly provider.");
+        BinaryWebSocketFrame frame = new BinaryWebSocketFrame(wrappedBuffer(fragment, offset, len));
+        frame.setFinalFragment(last);
+        channel.write(frame);
+        return this;
     }
 
     @Override
@@ -88,7 +94,10 @@ public WebSocket sendTextMessage(String message) {
 
     @Override
     public WebSocket streamText(String fragment, boolean last) {
-        throw new UnsupportedOperationException("Streaming currently only supported by the Grizzly provider.");
+        TextWebSocketFrame frame = new TextWebSocketFrame(fragment);
+        frame.setFinalFragment(last);
+        channel.write(frame);
+        return this;
     }
 
     @Override