diff --git a/internal/broker/broker.go b/internal/broker/broker.go index a42fdb7..b3fa1c5 100644 --- a/internal/broker/broker.go +++ b/internal/broker/broker.go @@ -306,7 +306,7 @@ func (b *Broker) waitConnsQuiet(ctx context.Context, states []*connState) bool { st.mu.Lock() ch := st.downCh st.mu.Unlock() - if ch != nil && len(ch) > 0 { + if len(ch) > 0 { quiet = false break }