From d2af3b1183534dea66363a4c1ec00ad3fb7f8c5c Mon Sep 17 00:00:00 2001 From: nquidox Date: Fri, 20 Feb 2026 14:25:34 +0300 Subject: [PATCH] added chan --- handler.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/handler.go b/handler.go index e50dd94..eacd93b 100644 --- a/handler.go +++ b/handler.go @@ -64,7 +64,7 @@ func NewClient(deps Deps) *Client { func StartConsumer(ctx context.Context, client *Client, chanLen int) chan []byte { msgCh := make(chan []byte, chanLen) - go runConsumer(ctx, client) + go runConsumer(ctx, client, msgCh) return msgCh }