From 53ea1cd2d0222acbb1cfde619589cc4e364bf9b7 Mon Sep 17 00:00:00 2001
From: Ali Najafizadeh <a.najafizadeh@gmail.com>
Date: Thu, 2 May 2024 11:18:17 -0400
Subject: [PATCH] Fix intialization issue with closeSignal channel

---
 server/server.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/server/server.go b/server/server.go
index 3933a94..1ad0346 100644
--- a/server/server.go
+++ b/server/server.go
@@ -574,6 +574,7 @@ func New(ctx context.Context, opts ...Opt) (*Handler, error) {
 	h := &Handler{
 		consumersEventsMap: NewConsumersEventsMap(),
 		actions:            NewActions(conf.workerBufferSize),
+		closeSignal:        make(chan struct{}),
 	}
 
 	go h.processActions()