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 }