Skip to content

Commit a63b4f6

Browse files
committed
Do not block the WebSocket from receiving bytes or text fragments
1 parent b455a94 commit a63b4f6

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

src/main/java/com/ning/http/client/providers/netty/ws/NettyWebSocket.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -186,10 +186,8 @@ private boolean hasWebSocketTextListener() {
186186
@Override
187187
public WebSocket addWebSocketListener(WebSocketListener l) {
188188
listeners.add(l);
189-
if (l instanceof WebSocketByteListener)
190-
interestedInByteMessages = true;
191-
else if (l instanceof WebSocketTextListener)
192-
interestedInTextMessages = true;
189+
interestedInByteMessages = interestedInByteMessages || l instanceof WebSocketByteListener;
190+
interestedInTextMessages = interestedInTextMessages || l instanceof WebSocketTextListener;
193191
return this;
194192
}
195193

@@ -199,7 +197,7 @@ public WebSocket removeWebSocketListener(WebSocketListener l) {
199197

200198
if (l instanceof WebSocketByteListener)
201199
interestedInByteMessages = hasWebSocketByteListener();
202-
else if (l instanceof WebSocketTextListener)
200+
if (l instanceof WebSocketTextListener)
203201
interestedInTextMessages = hasWebSocketTextListener();
204202

205203
return this;

0 commit comments

Comments
 (0)