Skip to content

Commit 2d5ce45

Browse files
committed
bugfix: close a closed channel
1 parent 7aa7a9a commit 2d5ce45

File tree

1 file changed

+5
-8
lines changed

1 file changed

+5
-8
lines changed

http.go

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -221,7 +221,7 @@ func NewHTTPRequest(config *Config) (request *http.Request, err error) {
221221

222222
var body io.Reader
223223

224-
if (config.method == "POST" || config.method == "PUT") && config.bodyContent != nil {
224+
if config.method == "POST" || config.method == "PUT" {
225225
body = bytes.NewReader(config.bodyContent)
226226
}
227227

@@ -258,14 +258,11 @@ func NewHTTPRequest(config *Config) (request *http.Request, err error) {
258258
}
259259

260260
func CopyHTTPRequest(config *Config, request *http.Request) *http.Request {
261-
if config.method == "POST" || config.method == "PUT" {
262-
newRequest := *request
263-
if newRequest.Body != nil {
264-
newRequest.Body = ioutil.NopCloser(bytes.NewReader(config.bodyContent))
265-
}
266-
return &newRequest
261+
newRequest := *request
262+
if request.Body != nil {
263+
newRequest.Body = ioutil.NopCloser(bytes.NewReader(config.bodyContent))
267264
}
268-
return request
265+
return &newRequest
269266
}
270267

271268
type LengthError struct {

0 commit comments

Comments
 (0)