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

fukua95 · ndyakov · commit cb2cfb000d53 · 2025-04-30T13:37:42.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)...)`