From 3bbaae4589de56da9ab09360aa28a3cd12198471 Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Tue, 9 Oct 2018 14:29:47 +0300
Subject: MessageReadEvent refactoring

---
 .../src/main/java/com/juick/components/NotificationsManager.java      | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

(limited to 'juick-notifications/src/main/java/com/juick/components/NotificationsManager.java')

diff --git a/juick-notifications/src/main/java/com/juick/components/NotificationsManager.java b/juick-notifications/src/main/java/com/juick/components/NotificationsManager.java
index be97ea40..fce0bed7 100644
--- a/juick-notifications/src/main/java/com/juick/components/NotificationsManager.java
+++ b/juick-notifications/src/main/java/com/juick/components/NotificationsManager.java
@@ -103,7 +103,9 @@ public class NotificationsManager extends TextWebSocketHandler {
                 jmsg.getUser().getUid()),
                 HttpMethod.GET, null, new ParameterizedTypeReference<List<User>>() {
                 }).getBody();
-        applicationEventPublisher.publishEvent(new MessageReadEvent(this, users, jmsg));
+        users.forEach(user -> {
+            applicationEventPublisher.publishEvent(new MessageReadEvent(this, user, jmsg));
+        });
     }
 
     public void addInvalidGCMToken(String token) {
-- 
cgit v1.2.3