diff --git a/internal/streams/streams.go b/internal/streams/streams.go
index 7930a645..1bab036e 100644
--- a/internal/streams/streams.go
+++ b/internal/streams/streams.go
@@ -64,9 +64,8 @@ func New(name string, source string) *Stream {
 	stream := NewStream(source)
 
 	streamsMu.Lock()
-	defer streamsMu.Unlock()
-
 	streams[name] = stream
+	streamsMu.Unlock()
 	return stream
 }