diff --git a/pkg/impl/signal-server/signaling.go b/pkg/impl/signal-server/signaling.go index f56e662..66623c8 100644 --- a/pkg/impl/signal-server/signaling.go +++ b/pkg/impl/signal-server/signaling.go @@ -130,6 +130,9 @@ func (signalingServer SignalingServer) handleRedisPubSub(ctx context.Context, na return err } case signalingServer.redisKeyPrefix + ":" + room + ":discover:" + name: + if msg.Payload == name { + continue + } if err := stream.Send(&proto.SignalingMessage{ Room: room, Sender: msg.Payload,