From a5105b0ddb36098cf6c62b46f3dd9030a11500aa Mon Sep 17 00:00:00 2001 From: Peter Stuifzand Date: Sun, 17 Apr 2022 00:23:05 +0200 Subject: [PATCH] Problem: 0 unread items are not sent Solution: remove check for unread, it's not working --- cmd/eksterd/memory.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/cmd/eksterd/memory.go b/cmd/eksterd/memory.go index 682a61d..d4d4d40 100644 --- a/cmd/eksterd/memory.go +++ b/cmd/eksterd/memory.go @@ -869,13 +869,10 @@ func (b *memoryBackend) updateChannelUnreadCount(channel string) error { var c microsub.Channel c.UID = channel - currentCount := c.Unread.UnreadCount c.Unread = microsub.Unread{Type: microsub.UnreadCount, UnreadCount: unread} // Sent message to Server-Sent-Events - if currentCount != unread { - b.broker.Notifier <- sse.Message{Event: "new item in channel", Object: c} - } + b.broker.Notifier <- sse.Message{Event: "new item in channel", Object: c} return nil }