From 8ab8bbb0d424145c42e94af8d77d927e9b70bc82 Mon Sep 17 00:00:00 2001 From: DieGurke <55625494+DieGurke@users.noreply.github.com> Date: Wed, 8 Jul 2020 13:55:19 +0200 Subject: [PATCH] Extracted into local variable Co-authored-by: delvh --- .../server/processors/GroupMessageStatusChangeProcessor.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/envoy/server/processors/GroupMessageStatusChangeProcessor.java b/src/main/java/envoy/server/processors/GroupMessageStatusChangeProcessor.java index cc86e0c..fa3bcb2 100644 --- a/src/main/java/envoy/server/processors/GroupMessageStatusChangeProcessor.java +++ b/src/main/java/envoy/server/processors/GroupMessageStatusChangeProcessor.java @@ -45,10 +45,11 @@ public class GroupMessageStatusChangeProcessor implements ObjectProcessor connectionManager.getUserIDBySocketID(socketID) != k) + .filter(k -> userID != k) .filter(connectionManager::isOnline) .forEach(k -> writeProxy.write(connectionManager.getSocketID(k), statusChange));