Sha256: ad73eeae50be1d005c8571409f28cb20511a5e2211ce54fbac4e9077696a62db
Contents?: true
Size: 1.24 KB
Versions: 30
Compression:
Stored size: 1.24 KB
Contents
module Excon
module Middleware
class Idempotent < Excon::Middleware::Base
def error_call(datum)
if datum[:idempotent]
if datum.has_key?(:request_block)
if datum[:request_block].respond_to?(:rewind)
datum[:request_block].rewind
else
Excon.display_warning('Excon requests with a :request_block must implement #rewind in order to be :idempotent.')
datum[:idempotent] = false
end
end
if datum.has_key?(:pipeline)
Excon.display_warning("Excon requests can not be :idempotent when pipelining.")
datum[:idempotent] = false
end
end
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
connection = datum.delete(:connection)
datum.reject! {|key, _| !Excon::VALID_REQUEST_KEYS.include?(key) }
connection.request(datum)
else
@stack.error_call(datum)
end
end
end
end
end
Version data entries
30 entries across 30 versions & 4 rubygems