Add:

 - streaming support
 - the ability to send pings and pongs

 Tests to come in another commit.

Author: rlubke

pom.xml

@@ -447,7 +447,7 @@
                 <dependency>
                     <groupId>org.glassfish.grizzly</groupId>
                     <artifactId>grizzly-websockets</artifactId>
-                    <version>2.2</version>
+                    <version>2.2.1</version>
                     <optional>true</optional>
                 </dependency>
             </dependencies>

src/main/java/com/ning/http/client/providers/grizzly/GrizzlyAsyncHttpProvider.java

@@ -2557,12 +2557,46 @@ public WebSocket sendMessage(byte[] message) {
             return this;
         }
 
+        @Override
+        public WebSocket stream(byte[] fragment, boolean last) {
+            if (fragment != null && fragment.length > 0) {
+                gWebSocket.stream(last, fragment, 0, fragment.length);
+            }
+            return this;
+        }
+
+        @Override
+        public WebSocket stream(byte[] fragment, int offset, int len, boolean last) {
+            if (fragment != null && fragment.length > 0) {
+                gWebSocket.stream(last, fragment, offset, len);
+            }
+            return this;
+        }
+
         @Override
         public WebSocket sendTextMessage(String message) {
             gWebSocket.send(message);
             return this;
         }
 
+        @Override
+        public WebSocket streamText(String fragment, boolean last) {
+            gWebSocket.stream(last, fragment);
+            return this;
+        }
+
+        @Override
+        public WebSocket sendPing(byte[] payload) {
+            gWebSocket.sendPing(payload);
+            return this;
+        }
+
+        @Override
+        public WebSocket sendPong(byte[] payload) {
+            gWebSocket.sendPong(payload);
+            return this;
+        }
+
         @Override
         public WebSocket addMessageListener(WebSocketListener l) {
             gWebSocket.add(new AHCWebSocketListenerAdapter(l, this));

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

@@ -13,15 +13,15 @@
 package com.ning.http.client.providers.netty;
 
 import com.ning.http.client.providers.netty.netty4.BinaryWebSocketFrame;
+import com.ning.http.client.providers.netty.netty4.PingWebSocketFrame;
+import com.ning.http.client.providers.netty.netty4.PongWebSocketFrame;
 import com.ning.http.client.providers.netty.netty4.TextWebSocketFrame;
 import com.ning.http.client.websocket.WebSocket;
 import com.ning.http.client.websocket.WebSocketByteListener;
 import com.ning.http.client.websocket.WebSocketListener;
 import com.ning.http.client.websocket.WebSocketTextListener;
-import org.jboss.netty.buffer.ChannelBuffers;
 import org.jboss.netty.channel.Channel;
 
-import java.io.UnsupportedEncodingException;
 import java.util.concurrent.ConcurrentLinkedQueue;
 
 import static org.jboss.netty.buffer.ChannelBuffers.wrappedBuffer;
@@ -41,12 +41,46 @@ public WebSocket sendMessage(byte[] message) {
         return this;
     }
 
+    @Override
+    public WebSocket stream(byte[] fragment, boolean last) {
+        if (fragment != null && fragment.length > 0) {
+            channel.write(new BinaryWebSocketFrame(last, 0, wrappedBuffer(fragment)));
+        }
+        return this;
+    }
+
+    @Override
+    public WebSocket stream(byte[] fragment, int offset, int len, boolean last) {
+        if (fragment != null && fragment.length > 0) {
+            channel.write(new BinaryWebSocketFrame(last, 0, wrappedBuffer(fragment, offset,  len)));
+        }
+        return this;
+    }
+
     @Override
     public WebSocket sendTextMessage(String message) {
         channel.write(new TextWebSocketFrame(message));
         return this;
     }
 
+    @Override
+    public WebSocket streamText(String fragment, boolean last) {
+        channel.write(new TextWebSocketFrame(last, 0, fragment));
+        return this;
+    }
+
+    @Override
+    public WebSocket sendPing(byte[] payload) {
+        channel.write(new PingWebSocketFrame(wrappedBuffer(payload)));
+        return this;
+    }
+    
+    @Override
+    public WebSocket sendPong(byte[] payload) {
+        channel.write(new PongWebSocketFrame(wrappedBuffer(payload)));
+        return this;
+    }
+
     @Override
     public WebSocket addMessageListener(WebSocketListener l) {
         listeners.add(l);

src/main/java/com/ning/http/client/websocket/WebSocket.java

@@ -18,19 +18,68 @@
 public interface WebSocket {
 
     /**
-     * Sen a byte message.
+     * Send a byte message.
      * @param message a byte message
      * @return this
      */
     WebSocket sendMessage(byte[] message);
 
+    /**
+     * Allows streaming of multiple binary fragments.
+     * 
+     * @param fragment binary fragment.
+     * @param last     flag indicating whether or not this is the last fragment.
+     *             
+     * @return this.
+     */
+    WebSocket stream(byte[] fragment, boolean last);
+
+    /**
+     * Allows streaming of multiple binary fragments.
+     *
+     * @param fragment binary fragment.
+     * @param offset   starting offset.
+     * @param len      length.
+     * @param last     flag indicating whether or not this is the last fragment.
+     * @return
+     */
+    WebSocket stream(byte[] fragment, int offset, int len, boolean last);
+
     /**
      * Send a text message
      * @param message a text message
      * @return this.
      */
     WebSocket sendTextMessage(String message);
 
+    /**
+     * Allows streaming of multiple text fragments.
+     *
+     * @param fragment text fragment.
+     * @param last     flag indicating whether or not this is the last fragment.
+     * @return this.
+     */
+    WebSocket streamText(String fragment, boolean last);
+
+    /**
+     * Send a <code>ping</ping> with an optional payload
+     * (limited to 125 bytes or less).
+     *
+     * @param payload the ping payload.
+     *
+     * @return this.
+     */
+    WebSocket sendPing(byte[] payload);
+
+    /**
+     * Send a <code>ping</ping> with an optional payload
+     * (limited to 125 bytes or less).
+     *
+     * @param payload the pong payload.
+     * @return this.
+     */
+    WebSocket sendPong(byte[] payload);
+
     /**
      * Add a {@link WebSocketListener}
      * @param l a {@link WebSocketListener}