Fix connect.CloseResponse

connectrpc · Oct 31, 2023 · 7ac9679 · 7ac9679
1 parent 3dafb2d
commit 7ac9679
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/protocol_connect.go b/protocol_connect.go
@@ -498,10 +498,7 @@ func (cc *connectUnaryClientConn) ResponseTrailer() http.Header {
 }
 
 func (cc *connectUnaryClientConn) CloseResponse() error {
-	if response := cc.call.response; response != nil {
-		return response.Body.Close()
-	}
-	return nil
+	return cc.call.CloseRead()
 }
 
 func (cc *connectUnaryClientConn) onRequestSend(fn func(*http.Request)) {