diff options
| -rw-r--r-- | juick-server/src/main/java/com/juick/server/ServerManager.java | 18 |
1 files changed, 8 insertions, 10 deletions
diff --git a/juick-server/src/main/java/com/juick/server/ServerManager.java b/juick-server/src/main/java/com/juick/server/ServerManager.java index 4f25929b..fce92705 100644 --- a/juick-server/src/main/java/com/juick/server/ServerManager.java +++ b/juick-server/src/main/java/com/juick/server/ServerManager.java @@ -244,16 +244,14 @@ public class ServerManager implements NotificationListener { public void sendSseEvent(Message msg, List<User> subscribers) { List<EventSession> deadEmitters = new ArrayList<>(); - synchronized (this.getSessions()) { - this.sessions.stream().filter(s -> subscribers.contains(s.user)).forEach(session -> { - try { - session.getEmitter().send(msg); - } catch (Exception e) { - deadEmitters.add(session); - } - }); - this.sessions.removeAll(deadEmitters); - } + this.sessions.stream().filter(s -> subscribers.contains(s.user)).forEach(session -> { + try { + session.getEmitter().send(msg); + } catch (Exception e) { + deadEmitters.add(session); + } + }); + this.sessions.removeAll(deadEmitters); } public static class EventSession { |