fix: PubSub isn't concurrency-safe (#3360)

fukua95 · web-flow · commit bb8d50848185 · 2025-04-29T09:39:26.000+03:00
diff --git a/pubsub.go b/pubsub.go
@@ -45,6 +45,9 @@ func (c *PubSub) init() {
 }
 
 func (c *PubSub) String() string {
+	c.mu.Lock()
+	defer c.mu.Unlock()
+
 	channels := mapKeys(c.channels)
 	channels = append(channels, mapKeys(c.patterns)...)
 	channels = append(channels, mapKeys(c.schannels)...)

Original file line number	Diff line number	Diff line change
`@@ -45,6 +45,9 @@ func (c *PubSub) init() {`
`45`	`45`	`}`
`46`	`46`
`47`	`47`	`func (c *PubSub) String() string {`
	`48`	`+ c.mu.Lock()`
	`49`	`+ defer c.mu.Unlock()`
	`50`	`+`
`48`	`51`	`channels := mapKeys(c.channels)`
`49`	`52`	`channels = append(channels, mapKeys(c.patterns)...)`
`50`	`53`	`channels = append(channels, mapKeys(c.schannels)...)`