WS streaming feature restricted to Grizzly provider for the time being.

Author: rlubke

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

@@ -43,18 +43,12 @@ public WebSocket sendMessage(byte[] message) {
 
     @Override
     public WebSocket stream(byte[] fragment, boolean last) {
-        if (fragment != null && fragment.length > 0) {
-            channel.write(new BinaryWebSocketFrame(last, 0, wrappedBuffer(fragment)));
-        }
-        return this;
+        throw new UnsupportedOperationException("Streaming currently only supported by the Grizzly provider.");
     }
 
     @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;
+        throw new UnsupportedOperationException("Streaming currently only supported by the Grizzly provider.");
     }
 
     @Override
@@ -65,8 +59,7 @@ public WebSocket sendTextMessage(String message) {
 
     @Override
     public WebSocket streamText(String fragment, boolean last) {
-        channel.write(new TextWebSocketFrame(last, 0, fragment));
-        return this;
+        throw new UnsupportedOperationException("Streaming currently only supported by the Grizzly provider.");
     }
 
     @Override

src/test/java/com/ning/http/client/websocket/ByteMessageTest.java

@@ -200,7 +200,7 @@ public void onFragment(byte[] fragment, boolean last) {
             assertEquals(text.get(), "ECHOECHO".getBytes());
     }
 
-    @Test
+
     public void echoFragments() throws Exception {
         AsyncHttpClient c = getAsyncHttpClient(new AsyncHttpClientConfig.Builder().build());
                 final CountDownLatch latch = new CountDownLatch(1);

src/test/java/com/ning/http/client/websocket/TextMessageTest.java

@@ -312,7 +312,7 @@ public void onError(Throwable t) {
         assertEquals(text.get(), "ECHOECHO");
     }
 
-    @Test(timeOut = 60000)
+
     public void echoFragments() throws Throwable {
         AsyncHttpClient c = getAsyncHttpClient(new AsyncHttpClientConfig.Builder().build());
         final CountDownLatch latch = new CountDownLatch(1);

src/test/java/com/ning/http/client/websocket/grizzly/GrizzlyByteMessageTest.java

@@ -17,6 +17,7 @@
 import com.ning.http.client.async.ProviderUtil;
 import com.ning.http.client.providers.grizzly.GrizzlyAsyncHttpProvider;
 import com.ning.http.client.websocket.ByteMessageTest;
+import org.testng.annotations.Test;
 
 public class GrizzlyByteMessageTest extends ByteMessageTest {
     @Override
@@ -26,4 +27,10 @@ public AsyncHttpClient getAsyncHttpClient(AsyncHttpClientConfig config) {
         }
         return new AsyncHttpClient(new GrizzlyAsyncHttpProvider(config), config);
     }
+
+    @Test(timeOut = 60000)
+    @Override
+    public void echoFragments() throws Exception {
+        super.echoFragments();
+    }
 }

src/test/java/com/ning/http/client/websocket/grizzly/GrizzlyTextMessageTest.java

@@ -17,6 +17,7 @@
 import com.ning.http.client.async.ProviderUtil;
 import com.ning.http.client.providers.grizzly.GrizzlyAsyncHttpProvider;
 import com.ning.http.client.websocket.ByteMessageTest;
+import org.testng.annotations.Test;
 
 public class GrizzlyTextMessageTest extends ByteMessageTest {
     @Override
@@ -26,4 +27,10 @@ public AsyncHttpClient getAsyncHttpClient(AsyncHttpClientConfig config) {
         }
         return new AsyncHttpClient(new GrizzlyAsyncHttpProvider(config), config);
     }
+
+    @Test(timeOut = 60000)
+    @Override
+    public void echoFragments() throws Exception {
+        super.echoFragments();    //To change body of overridden methods use File | Settings | File Templates.
+    }
 }