BC-18492

request.go

@@ -656,7 +656,10 @@ func (r *Request) Do(ctx ...context.Context) *Response {
 	if r.error != nil {
 		return r.newErrorResponse(r.error)
 	}
-	if r.retryOption != nil && r.retryOption.MaxRetries != 0 && r.unReplayableBody != nil { // retryable request should not have unreplayable Body
+	if r.retryOption != nil &&
+		r.retryOption.MaxRetries != 0 &&
+		!r.retryOption.SkipCheckingBody &&
+		r.unReplayableBody != nil { // retryable request should not have unreplayable Body
 		return r.newErrorResponse(errRetryableWithUnReplayableBody)
 	}
 	resp, _ := r.do()
@@ -1229,6 +1232,22 @@ func (r *Request) AddRetryCondition(condition RetryConditionFunc) *Request {
 	return r
 }
 
+// EnableSkipCheckingBody skips checking for an unreplayable body to allow the
+// caller to handle the body explicitly on retries.
+func (r *Request) EnableSkipCheckingBody() *Request {
+	ro := r.getRetryOption()
+	ro.SkipCheckingBody = true
+	return r
+}
+
+// DisableSkipCheckingBody enables checking for an unreplayable body to protect
+// the caller from mishandling the body.
+func (r *Request) DisableSkipCheckingBody() *Request {
+	ro := r.getRetryOption()
+	ro.SkipCheckingBody = false
+	return r
+}
+
 // SetClient change the client of request dynamically.
 func (r *Request) SetClient(client *Client) *Request {
 	if client != nil {

retry.go

@@ -43,6 +43,7 @@ type retryOption struct {
 	GetRetryInterval GetRetryIntervalFunc
 	RetryConditions  []RetryConditionFunc
 	RetryHooks       []RetryHookFunc
+	SkipCheckingBody bool
 }
 
 func (ro *retryOption) Clone() *retryOption {
@@ -52,6 +53,7 @@ func (ro *retryOption) Clone() *retryOption {
 	o := &retryOption{
 		MaxRetries:       ro.MaxRetries,
 		GetRetryInterval: ro.GetRetryInterval,
+		SkipCheckingBody: ro.SkipCheckingBody,
 	}
 	o.RetryConditions = append(o.RetryConditions, ro.RetryConditions...)
 	o.RetryHooks = append(o.RetryHooks, ro.RetryHooks...)