diff --git a/internal/transport/controlbuf.go b/internal/transport/controlbuf.go index e57bb5ea2194..f1fb7b69dfd4 100644 --- a/internal/transport/controlbuf.go +++ b/internal/transport/controlbuf.go @@ -407,7 +407,6 @@ func (c *controlBuffer) get(block bool) (interface{}, error) { select { case <-c.ch: case <-c.done: - c.finish() return nil, ErrConnClosing } }