class Aws::S3::Plugins::StreamingRetry::Handler

def retryable_body?(context)
  context.http_response.body.is_a?(RetryableBlockIO) ||
    context.http_response.body.is_a?(RetryableManagedFile)
end