From 8128edad43ae63357d336faf0bb3030163d2efb0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Michele=20Pr=C3=A0?= Date: Mon, 16 Sep 2024 16:42:22 +0200 Subject: [PATCH] Update streams.go --- internal/streams/streams.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 }