aboutsummaryrefslogtreecommitdiff
path: root/juick-ws/src/main/java
diff options
context:
space:
mode:
authorGravatar Vitaly Takmazov2017-02-03 12:54:55 +0300
committerGravatar Vitaly Takmazov2017-02-03 12:54:55 +0300
commit9742e8e43bfb29b83b5a8a88be7cc6610116d7c5 (patch)
treea43a3dd8a150f301d36c8b3dfd45becb49a6f856 /juick-ws/src/main/java
parent463d66fce7ef0dfea2afd537e9ef51b5ddf322da (diff)
cleanup
Diffstat (limited to 'juick-ws/src/main/java')
-rw-r--r--juick-ws/src/main/java/com/juick/ws/WebsocketComponent.java7
1 files changed, 1 insertions, 6 deletions
diff --git a/juick-ws/src/main/java/com/juick/ws/WebsocketComponent.java b/juick-ws/src/main/java/com/juick/ws/WebsocketComponent.java
index 2b69ea7d..8d0c3d76 100644
--- a/juick-ws/src/main/java/com/juick/ws/WebsocketComponent.java
+++ b/juick-ws/src/main/java/com/juick/ws/WebsocketComponent.java
@@ -125,12 +125,7 @@ public class WebsocketComponent extends TextWebSocketHandler implements Protocol
public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
synchronized (clients) {
logger.info("session closed with status {}: {}", status.getCode(), status.getReason());
- clients.removeIf(c -> {
- if (c.session.getId().equals(session.getId())) {
- return true;
- }
- return false;
- });
+ clients.removeIf(c -> c.session.getId().equals(session.getId()));
logger.info("{} clients connected", clients.size());
}