@@ -48,9 +48,6 @@ public void bufferFrame(Runnable bufferedFrame) {
48
48
bufferedFrames .add (bufferedFrame );
49
49
}
50
50
51
- /**
52
- * {@inheritDoc}
53
- */
54
51
@ Override
55
52
public final void onThrowable (Throwable t ) {
56
53
onFailure (t );
@@ -62,37 +59,24 @@ public boolean touchSuccess() {
62
59
return prev ;
63
60
}
64
61
65
- /**
66
- * {@inheritDoc}
67
- */
68
62
@ Override
69
63
public final State onBodyPartReceived (HttpResponseBodyPart bodyPart ) throws Exception {
70
64
return State .CONTINUE ;
71
65
}
72
66
73
- /**
74
- * {@inheritDoc}
75
- */
76
67
@ Override
77
68
public final State onStatusReceived (HttpResponseStatus responseStatus ) throws Exception {
78
69
status = responseStatus .getStatusCode ();
79
70
return status == SWITCHING_PROTOCOLS ? State .UPGRADE : State .ABORT ;
80
71
}
81
72
82
- /**
83
- * {@inheritDoc}
84
- */
85
73
@ Override
86
74
public final State onHeadersReceived (HttpResponseHeaders headers ) throws Exception {
87
75
return State .CONTINUE ;
88
76
}
89
77
90
- /**
91
- * {@inheritDoc}
92
- */
93
78
@ Override
94
79
public final WebSocket onCompleted () throws Exception {
95
-
96
80
if (status != SWITCHING_PROTOCOLS ) {
97
81
IllegalStateException e = new IllegalStateException ("Invalid Status Code " + status );
98
82
for (WebSocketListener listener : listeners ) {
@@ -104,9 +88,6 @@ public final WebSocket onCompleted() throws Exception {
104
88
return webSocket ;
105
89
}
106
90
107
- /**
108
- * {@inheritDoc}
109
- */
110
91
@ Override
111
92
public final void onSuccess (WebSocket webSocket ) {
112
93
this .webSocket = webSocket ;
@@ -123,9 +104,6 @@ public final void onSuccess(WebSocket webSocket) {
123
104
ok .set (true );
124
105
}
125
106
126
- /**
127
- * {@inheritDoc}
128
- */
129
107
@ Override
130
108
public final void onFailure (Throwable t ) {
131
109
for (WebSocketListener listener : listeners ) {
@@ -136,22 +114,6 @@ public final void onFailure(Throwable t) {
136
114
}
137
115
}
138
116
139
- public final void onClose (WebSocket webSocket , int status , String reasonPhrase ) {
140
- // Connect failure
141
- if (this .webSocket == null )
142
- this .webSocket = webSocket ;
143
-
144
- for (WebSocketListener listener : listeners ) {
145
- if (webSocket != null ) {
146
- webSocket .addWebSocketListener (listener );
147
- }
148
- listener .onClose (webSocket );
149
- if (listener instanceof WebSocketCloseCodeReasonListener ) {
150
- WebSocketCloseCodeReasonListener .class .cast (listener ).onClose (webSocket , status , reasonPhrase );
151
- }
152
- }
153
- }
154
-
155
117
/**
156
118
* Build a {@link WebSocketUpgradeHandler}
157
119
*/
0 commit comments