Update streams.go

2024-09-16 16:42:22 +02:00
parent eb8a13d8c2
commit 8128edad43
1 changed files with 2 additions and 1 deletions
@@ -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
 }