Merge pull request #1355 from michelepra/concurrent_map_fix

data race for streams map
AlexxIT · Sep 27, 2024 · ef7d898 · ef7d898
2 parents 7b77e41 + 388c408
commit ef7d898
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/streams/streams.go b/internal/streams/streams.go
@@ -62,7 +62,10 @@ func New(name string, source string) *Stream {
 	}
 
 	stream := NewStream(source)
+
+	streamsMu.Lock()
 	streams[name] = stream
+	streamsMu.Unlock()
 	return stream
 }