File tree Expand file tree Collapse file tree 1 file changed +11
-11
lines changed
src/main/java/com/ning/http/client/providers/netty Expand file tree Collapse file tree 1 file changed +11
-11
lines changed Original file line number Diff line number Diff line change @@ -39,63 +39,63 @@ public NettyWebSocket(Channel channel) {
3939 this .channel = channel ;
4040 }
4141
42- @ Override
42+ // @Override
4343 public WebSocket sendMessage (byte [] message ) {
4444 channel .write (new BinaryWebSocketFrame (wrappedBuffer (message )));
4545 return this ;
4646 }
4747
48- @ Override
48+ // @Override
4949 public WebSocket stream (byte [] fragment , boolean last ) {
5050 throw new UnsupportedOperationException ("Streaming currently only supported by the Grizzly provider." );
5151 }
5252
53- @ Override
53+ // @Override
5454 public WebSocket stream (byte [] fragment , int offset , int len , boolean last ) {
5555 throw new UnsupportedOperationException ("Streaming currently only supported by the Grizzly provider." );
5656 }
5757
58- @ Override
58+ // @Override
5959 public WebSocket sendTextMessage (String message ) {
6060 channel .write (new TextWebSocketFrame (message ));
6161 return this ;
6262 }
6363
64- @ Override
64+ // @Override
6565 public WebSocket streamText (String fragment , boolean last ) {
6666 throw new UnsupportedOperationException ("Streaming currently only supported by the Grizzly provider." );
6767 }
6868
69- @ Override
69+ // @Override
7070 public WebSocket sendPing (byte [] payload ) {
7171 channel .write (new PingWebSocketFrame (wrappedBuffer (payload )));
7272 return this ;
7373 }
7474
75- @ Override
75+ // @Override
7676 public WebSocket sendPong (byte [] payload ) {
7777 channel .write (new PongWebSocketFrame (wrappedBuffer (payload )));
7878 return this ;
7979 }
8080
81- @ Override
81+ // @Override
8282 public WebSocket addWebSocketListener (WebSocketListener l ) {
8383 listeners .add (l );
8484 return this ;
8585 }
8686
87- @ Override
87+ // @Override
8888 public WebSocket removeWebSocketListener (WebSocketListener l ) {
8989 listeners .remove (l );
9090 return this ;
9191 }
9292
93- @ Override
93+ // @Override
9494 public boolean isOpen () {
9595 return channel .isOpen ();
9696 }
9797
98- @ Override
98+ // @Override
9999 public void close () {
100100 onClose ();
101101 listeners .clear ();
You can’t perform that action at this time.
0 commit comments