Merge pull request #1355 from michelepra/concurrent_map_fix

data race for streams map

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
 }