diff --git a/internal/streams/streams.go b/internal/streams/streams.go
index ff0f5654..7502c7d5 100644
--- a/internal/streams/streams.go
+++ b/internal/streams/streams.go
@@ -61,6 +61,9 @@ func New(name string, source string) *Stream {
 		return nil
 	}
 
+	streamsMu.Lock()
+	defer streamsMu.Unlock()
+
 	stream := NewStream(source)
 	streams[name] = stream
 	return stream