Rename sendTextMessage into sendMessage and streamText into stream, close AsyncHttpClient#671

Author: Stephane Landelle

api/src/main/java/org/asynchttpclient/websocket/WebSocket.java

@@ -52,7 +52,7 @@ public interface WebSocket extends Closeable {
      * @param message a text message
      * @return this.
      */
-    WebSocket sendTextMessage(String message);
+    WebSocket sendMessage(String message);
 
     /**
      * Allows streaming of multiple text fragments.
@@ -61,7 +61,7 @@ public interface WebSocket extends Closeable {
      * @param last     flag indicating whether or not this is the last fragment.
      * @return this.
      */
-    WebSocket streamText(String fragment, boolean last);
+    WebSocket stream(String fragment, boolean last);
 
     /**
      * Send a <code>ping</ping> with an optional payload

api/src/test/java/org/asynchttpclient/websocket/ProxyTunnellingTest.java

@@ -116,7 +116,7 @@ public void onError(Throwable t) {
                 }
             }).build()).get();
 
-            websocket.sendTextMessage("ECHO");
+            websocket.sendMessage("ECHO");
 
             latch.await();
             assertEquals(text.get(), "ECHO");

api/src/test/java/org/asynchttpclient/websocket/TextMessageTest.java

@@ -200,7 +200,7 @@ public void onError(Throwable t) {
                 }
             }).build()).get();
 
-            websocket.sendTextMessage("ECHO");
+            websocket.sendMessage("ECHO");
 
             latch.await();
             assertEquals(text.get(), "ECHO");
@@ -262,7 +262,7 @@ public void onError(Throwable t) {
                 }
             }).build()).get();
 
-            websocket.sendTextMessage("ECHO");
+            websocket.sendMessage("ECHO");
 
             latch.await();
             assertEquals(text.get(), "ECHOECHO");
@@ -288,7 +288,7 @@ public void onMessage(String message) {
 
                 @Override
                 public void onOpen(WebSocket websocket) {
-                    websocket.sendTextMessage("ECHO").sendTextMessage("ECHO");
+                    websocket.sendMessage("ECHO").sendMessage("ECHO");
                 }
 
                 @Override
@@ -340,8 +340,8 @@ public void onError(Throwable t) {
                 }
             }).build()).get();
 
-            websocket.streamText("ECHO", false);
-            websocket.streamText("ECHO", true);
+            websocket.stream("ECHO", false);
+            websocket.stream("ECHO", true);
 
             latch.await();
             assertEquals(text.get(), "ECHOECHO");
@@ -382,10 +382,10 @@ public void onError(Throwable t) {
                 }
             }).build()).get();
 
-            websocket.sendTextMessage("ECHO");
+            websocket.sendMessage("ECHO");
             textLatch.await();
 
-            websocket.sendTextMessage("CLOSE");
+            websocket.sendMessage("CLOSE");
             closeLatch.await();
 
             assertEquals(text.get(), "ECHO");

providers/grizzly/src/main/java/org/asynchttpclient/providers/grizzly/websocket/GrizzlyWebSocketAdapter.java

@@ -56,13 +56,13 @@ public WebSocket stream(byte[] fragment, int offset, int len, boolean last) {
     }
 
     @Override
-    public WebSocket sendTextMessage(String message) {
+    public WebSocket sendMessage(String message) {
         gWebSocket.send(message);
         return this;
     }
 
     @Override
-    public WebSocket streamText(String fragment, boolean last) {
+    public WebSocket stream(String fragment, boolean last) {
         gWebSocket.stream(last, fragment);
         return this;
     }

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

@@ -86,13 +86,13 @@ public WebSocket stream(byte[] fragment, int offset, int len, boolean last) {
     }
 
     @Override
-    public WebSocket sendTextMessage(String message) {
+    public WebSocket sendMessage(String message) {
         channel.writeAndFlush(new TextWebSocketFrame(message));
         return this;
     }
 
     @Override
-    public WebSocket streamText(String fragment, boolean last) {
+    public WebSocket stream(String fragment, boolean last) {
         channel.writeAndFlush(new TextWebSocketFrame(last, 0, fragment));
         return this;
     }