Fix intialization issue with closeSignal channel

ella-to · May 2, 2024 · 53ea1cd · 53ea1cd
1 parent f719514
commit 53ea1cd
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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()