diff --git a/internal/streams/streams.go b/internal/streams/streams.go
index ff0f5654c..1bab036e7 100644
--- 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
 }