diff --git a/transport/http_transport.go b/transport/http_transport.go index 1c892b53..4825b197 100644 --- a/transport/http_transport.go +++ b/transport/http_transport.go @@ -95,6 +95,7 @@ func (h *httpTransportClient) Recv(m *Message) error { } func (h *httpTransportClient) Close() error { + h.buff.Reset(nil) return h.conn.Close() }