Sha256: be65b014896c0c40672f1720f0534fe3f51d0a1fde66289cfbe9b8e98b482130
Contents?: true
Size: 666 Bytes
Versions: 12
Compression:
Stored size: 666 Bytes
Contents
module Excon
module Middleware
class Idempotent < Excon::Middleware::Base
def error_call(datum)
if datum[:idempotent] && [Excon::Errors::Timeout, Excon::Errors::SocketError,
Excon::Errors::HTTPStatusError].any? {|ex| datum[:error].kind_of?(ex) } && datum[:retries_remaining] > 1
# reduces remaining retries, reset connection, and restart request_call
datum[:retries_remaining] -= 1
datum[:connection].reset
datum.delete(:response)
datum.delete(:error)
datum[:connection].request(datum)
else
@stack.error_call(datum)
end
end
end
end
end
Version data entries
12 entries across 12 versions & 2 rubygems