diff options
author | Vitaly Takmazov | 2017-02-03 12:54:55 +0300 |
---|---|---|
committer | Vitaly Takmazov | 2017-02-03 12:54:55 +0300 |
commit | 9742e8e43bfb29b83b5a8a88be7cc6610116d7c5 (patch) | |
tree | a43a3dd8a150f301d36c8b3dfd45becb49a6f856 | |
parent | 463d66fce7ef0dfea2afd537e9ef51b5ddf322da (diff) |
cleanup
-rw-r--r-- | juick-ws/src/main/java/com/juick/ws/WebsocketComponent.java | 7 |
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()); } |