fix an extra response on discovery

2023-03-05 18:28:29 +08:00 · 2023-03-05 18:28:29 +08:00 · b9bdf202b5
commit b9bdf202b5
parent a6a002288b
1 changed files with 3 additions and 0 deletions
--- 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,