From 6685057dae14b28aa4d5652b0ac01fcac04419b7 Mon Sep 17 00:00:00 2001 From: Athou Date: Wed, 3 Jul 2024 17:27:17 +0200 Subject: [PATCH] notify over websocket after everything has been committed --- .../java/com/commafeed/backend/feed/FeedRefreshUpdater.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java b/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java index 8f4424c7..0383c6d3 100644 --- a/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java +++ b/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java @@ -171,8 +171,6 @@ public class FeedRefreshUpdater { List users = subscriptions.stream().map(FeedSubscription::getUser).toList(); cache.invalidateUnreadCount(subscriptions.toArray(new FeedSubscription[0])); cache.invalidateUserRootCategory(users.toArray(new User[0])); - - notifyOverWebsocket(unreadCountBySubscription); } } @@ -187,6 +185,8 @@ public class FeedRefreshUpdater { unitOfWork.run(() -> feedService.save(feed)); + notifyOverWebsocket(unreadCountBySubscription); + return processed; }