From fba10d93eb5447e2fcb34aa05c3f527ce006552e Mon Sep 17 00:00:00 2001 From: langhuihui <178529795@qq.com> Date: Thu, 12 Oct 2023 16:45:38 +0800 Subject: [PATCH] feat: add actionChan size --- stream.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/stream.go b/stream.go index 9d01312..3f9eded 100644 --- a/stream.go +++ b/stream.go @@ -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