This repository was archived by the owner on Mar 6, 2021. It is now read-only.
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) {
39
39
this .channel = channel ;
40
40
}
41
41
42
- @ Override
42
+ // @Override
43
43
public WebSocket sendMessage (byte [] message ) {
44
44
channel .write (new BinaryWebSocketFrame (wrappedBuffer (message )));
45
45
return this ;
46
46
}
47
47
48
- @ Override
48
+ // @Override
49
49
public WebSocket stream (byte [] fragment , boolean last ) {
50
50
throw new UnsupportedOperationException ("Streaming currently only supported by the Grizzly provider." );
51
51
}
52
52
53
- @ Override
53
+ // @Override
54
54
public WebSocket stream (byte [] fragment , int offset , int len , boolean last ) {
55
55
throw new UnsupportedOperationException ("Streaming currently only supported by the Grizzly provider." );
56
56
}
57
57
58
- @ Override
58
+ // @Override
59
59
public WebSocket sendTextMessage (String message ) {
60
60
channel .write (new TextWebSocketFrame (message ));
61
61
return this ;
62
62
}
63
63
64
- @ Override
64
+ // @Override
65
65
public WebSocket streamText (String fragment , boolean last ) {
66
66
throw new UnsupportedOperationException ("Streaming currently only supported by the Grizzly provider." );
67
67
}
68
68
69
- @ Override
69
+ // @Override
70
70
public WebSocket sendPing (byte [] payload ) {
71
71
channel .write (new PingWebSocketFrame (wrappedBuffer (payload )));
72
72
return this ;
73
73
}
74
74
75
- @ Override
75
+ // @Override
76
76
public WebSocket sendPong (byte [] payload ) {
77
77
channel .write (new PongWebSocketFrame (wrappedBuffer (payload )));
78
78
return this ;
79
79
}
80
80
81
- @ Override
81
+ // @Override
82
82
public WebSocket addWebSocketListener (WebSocketListener l ) {
83
83
listeners .add (l );
84
84
return this ;
85
85
}
86
86
87
- @ Override
87
+ // @Override
88
88
public WebSocket removeWebSocketListener (WebSocketListener l ) {
89
89
listeners .remove (l );
90
90
return this ;
91
91
}
92
92
93
- @ Override
93
+ // @Override
94
94
public boolean isOpen () {
95
95
return channel .isOpen ();
96
96
}
97
97
98
- @ Override
98
+ // @Override
99
99
public void close () {
100
100
onClose ();
101
101
listeners .clear ();
You can’t perform that action at this time.
0 commit comments