feat: add actionChan size

This commit is contained in:
langhuihui
2023-10-12 16:45:38 +08:00
parent d822e502a0
commit fba10d93eb

View File

@@ -286,7 +286,7 @@ func findOrCreateStream(streamPath string, waitTimeout time.Duration) (s *Stream
return s, false
} else {
s.Subscribers.Init()
s.actionChan.Init(1)
s.actionChan.Init(10)
s.Info("created")
go s.run()
return s, true