diff --git a/pkg/server/stream/v3/stream.go b/pkg/server/stream/v3/stream.go index a73083c7d5..4c1dc48b8d 100644 --- a/pkg/server/stream/v3/stream.go +++ b/pkg/server/stream/v3/stream.go @@ -115,8 +115,8 @@ func (s *StreamState) SetKnownResourceNamesAsList(url string, names []string) { } func (s *StreamState) GetKnownResourceNames(url string) map[string]struct{} { - s.mu.Lock() - defer s.mu.Unlock() + s.mu.RLock() + defer s.mu.RUnlock() return s.knownResourceNames[url] }