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