File tree 1 file changed +9
-10
lines changed
providers/netty/src/main/java/org/asynchttpclient/providers/netty/ws 1 file changed +9
-10
lines changed Original file line number Diff line number Diff line change @@ -196,29 +196,28 @@ public void onTextFragment(String message, boolean last) {
196
196
}
197
197
}
198
198
199
- for (WebSocketListener l : listeners ) {
200
- if (l instanceof WebSocketTextListener ) {
199
+ for (WebSocketListener listener : listeners ) {
200
+ if (listener instanceof WebSocketTextListener ) {
201
+ WebSocketTextListener textListener = (WebSocketTextListener ) listener ;
201
202
try {
202
203
if (!last ) {
203
- WebSocketTextListener . class . cast ( l ) .onFragment (message , last );
204
+ textListener .onFragment (message , last );
204
205
} else {
205
206
if (textBuffer .length () > 0 ) {
206
- WebSocketTextListener .class .cast (l ).onFragment (message , last );
207
-
208
- WebSocketTextListener .class .cast (l ).onMessage (textBuffer .append (message ).toString ());
207
+ textListener .onFragment (message , last );
208
+ textListener .onMessage (textBuffer .append (message ).toString ());
209
209
} else {
210
- WebSocketTextListener . class . cast ( l ) .onMessage (message );
210
+ textListener .onMessage (message );
211
211
}
212
212
}
213
213
} catch (Exception ex ) {
214
- l .onError (ex );
214
+ listener .onError (ex );
215
215
}
216
216
}
217
217
}
218
218
219
- if (last ) {
219
+ if (last )
220
220
textBuffer .setLength (0 );
221
- }
222
221
}
223
222
224
223
public void onError (Throwable t ) {
You can’t perform that action at this time.
0 commit comments