diff --git a/http.go b/http.go index 32d7aa0..2a354ec 100644 --- a/http.go +++ b/http.go @@ -40,7 +40,7 @@ type clientConn struct { cnl context.CancelCauseFunc } -func newClientConn(con net.Conn, closeFunc func(error)) *clientConn { +func NewClientConn(con net.Conn, closeFunc func(error)) *clientConn { ctx, cnl := context.WithCancelCause(context.TODO()) reader, writer := io.Pipe() c := &clientConn{ diff --git a/roundTripper.go b/roundTripper.go index 4410e31..32b168f 100644 --- a/roundTripper.go +++ b/roundTripper.go @@ -278,7 +278,7 @@ func (obj *roundTripper) dialConnecotr(ctx *Response, conne *connecotr, h2 bool) return err } } else { - conne.Conn = newClientConn(conne.c, func(err error) { + conne.Conn = NewClientConn(conne.c, func(err error) { conne.forceCnl(tools.WrapError(err, "http1 client close")) }) }