diff --git a/mtglib/proxy.go b/mtglib/proxy.go index 65f52ad..cb252ed 100644 --- a/mtglib/proxy.go +++ b/mtglib/proxy.go @@ -152,6 +152,7 @@ func (p *Proxy) Serve(listener net.Listener) error { case errors.Is(err, ants.ErrPoolClosed): return nil case errors.Is(err, ants.ErrPoolOverload): + conn.Close() //nolint: errcheck logger.Info("connection was concurrency limited") p.eventStream.Send(p.ctx, NewEventConcurrencyLimited()) }