From d62d41b41a4dcdd307d3280d8a9482cf2dd9184a Mon Sep 17 00:00:00 2001 From: nquidox Date: Thu, 2 Apr 2026 15:46:21 +0300 Subject: [PATCH] chan fix --- handler.go | 1 + 1 file changed, 1 insertion(+) diff --git a/handler.go b/handler.go index 9383673..249221f 100644 --- a/handler.go +++ b/handler.go @@ -48,6 +48,7 @@ func NewClient(addr, queueName string, opts ...Option) (*Client, error) { logger: log.New(os.Stdout, "", log.LstdFlags), queueName: queueName, done: make(chan bool), + connected: make(chan struct{}), } o := options{