diff --git a/common/signal/pubsub/pubsub.go b/common/signal/pubsub/pubsub.go index cc9b87eb1..0d3d17485 100644 --- a/common/signal/pubsub/pubsub.go +++ b/common/signal/pubsub/pubsub.go @@ -62,7 +62,7 @@ func (s *Service) Cleanup() error { } for name, subs := range s.subs { - newSub := make([]*Subscriber, 0, len(s.subs)) + newSub := make([]*Subscriber, 0, len(subs)) for _, sub := range subs { if !sub.IsClosed() { newSub = append(newSub, sub)