fix: publish broadcasts independently on local streams

anycable · Nov 2, 2023 · 9972f0e · 9972f0e
1 parent 7379c71
commit 9972f0e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/broker/memory.go b/broker/memory.go
@@ -239,9 +239,7 @@ func (b *Memory) HandleBroadcast(msg *common.StreamMessage) {
 	msg.Epoch = b.GetEpoch()
 	msg.Offset = offset
 
-	if b.tracker.Has(msg.Stream) {
-		b.broadcaster.Broadcast(msg)
-	}
+	b.broadcaster.Broadcast(msg)
 }
 
 func (b *Memory) HandleCommand(msg *common.RemoteCommandMessage) {

diff --git a/broker/nats.go b/broker/nats.go
@@ -328,9 +328,7 @@ func (n *NATS) HandleBroadcast(msg *common.StreamMessage) {
 	msg.Epoch = n.Epoch()
 	msg.Offset = offset
 
-	if n.tracker.Has(msg.Stream) {
-		n.broadcaster.Broadcast(msg)
-	}
+	n.broadcaster.Broadcast(msg)
 }
 
 func (n *NATS) HandleCommand(msg *common.RemoteCommandMessage) {