@@ -35,6 +35,12 @@ abstract class WebSocketDecoder implements WebSocketCallbacksFrameDecoder {
35
35
36
36
abstract WebSocketFrameFactory frameFactory ();
37
37
38
+ abstract void closeInbound ();
39
+
40
+ final void onFrameRead (ChannelHandlerContext ctx , boolean finFlag , int opcode , ByteBuf payload ) {
41
+ webSocketFrameListener .onChannelRead (ctx , finFlag , 0 , opcode , payload );
42
+ }
43
+
38
44
@ Override
39
45
public void channelInactive (ChannelHandlerContext ctx ) throws Exception {
40
46
WebSocketFrameListener listener = webSocketFrameListener ;
@@ -67,7 +73,7 @@ public void frameListener(
67
73
}
68
74
69
75
@ Override
70
- public void channelReadComplete (ChannelHandlerContext ctx ) {
76
+ public final void channelReadComplete (ChannelHandlerContext ctx ) {
71
77
WebSocketFrameListener listener = webSocketFrameListener ;
72
78
if (listener != null ) {
73
79
listener .onChannelReadComplete (ctx );
@@ -77,7 +83,7 @@ public void channelReadComplete(ChannelHandlerContext ctx) {
77
83
}
78
84
79
85
@ Override
80
- public void userEventTriggered (ChannelHandlerContext ctx , Object evt ) {
86
+ public final void userEventTriggered (ChannelHandlerContext ctx , Object evt ) {
81
87
WebSocketFrameListener listener = webSocketFrameListener ;
82
88
if (listener != null ) {
83
89
listener .onUserEventTriggered (ctx , evt );
@@ -87,7 +93,7 @@ public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
87
93
}
88
94
89
95
@ Override
90
- public void channelWritabilityChanged (ChannelHandlerContext ctx ) {
96
+ public final void channelWritabilityChanged (ChannelHandlerContext ctx ) {
91
97
WebSocketFrameListener listener = webSocketFrameListener ;
92
98
if (listener != null ) {
93
99
listener .onChannelWritabilityChanged (ctx );
@@ -98,7 +104,7 @@ public void channelWritabilityChanged(ChannelHandlerContext ctx) {
98
104
99
105
@ Override
100
106
@ SuppressWarnings ("deprecation" )
101
- public void exceptionCaught (ChannelHandlerContext ctx , Throwable cause ) {
107
+ public final void exceptionCaught (ChannelHandlerContext ctx , Throwable cause ) {
102
108
WebSocketFrameListener listener = webSocketFrameListener ;
103
109
if (listener != null ) {
104
110
listener .onExceptionCaught (ctx , cause );
@@ -107,26 +113,20 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
107
113
}
108
114
}
109
115
110
- abstract void closeInbound ();
111
-
112
- final void onFrameRead (ChannelHandlerContext ctx , boolean finFlag , int opcode , ByteBuf payload ) {
113
- webSocketFrameListener .onChannelRead (ctx , finFlag , 0 , opcode , payload );
114
- }
115
-
116
116
/*boilerplate*/
117
117
118
118
@ Override
119
- public void channelRegistered (ChannelHandlerContext ctx ) {
119
+ public final void channelRegistered (ChannelHandlerContext ctx ) {
120
120
ctx .fireChannelRegistered ();
121
121
}
122
122
123
123
@ Override
124
- public void channelUnregistered (ChannelHandlerContext ctx ) {
124
+ public final void channelUnregistered (ChannelHandlerContext ctx ) {
125
125
ctx .fireChannelUnregistered ();
126
126
}
127
127
128
128
@ Override
129
- public void channelActive (ChannelHandlerContext ctx ) {
129
+ public final void channelActive (ChannelHandlerContext ctx ) {
130
130
ctx .fireChannelActive ();
131
131
}
132
132
@@ -136,7 +136,7 @@ public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
136
136
}
137
137
138
138
@ Override
139
- public void handlerRemoved (ChannelHandlerContext ctx ) {
139
+ public final void handlerRemoved (ChannelHandlerContext ctx ) {
140
140
/*noop*/
141
141
}
142
142
}
0 commit comments