Class: Async::HTTP::Faraday::Adapter

Inherits:
Faraday::Adapter
  • Object
show all
Defined in:
lib/async/http/faraday/adapter.rb

Constant Summary collapse

CONNECTION_EXCEPTIONS = 
[
	Errno::EADDRNOTAVAIL,
	Errno::ECONNABORTED,
	Errno::ECONNREFUSED,
	Errno::ECONNRESET,
	Errno::EHOSTUNREACH,
	Errno::EINVAL,
	Errno::ENETUNREACH,
	Errno::EPIPE,
	IOError,
	SocketError
].freeze

Instance Method Summary collapse

Constructor Details

#initialize(*arguments, **options, &block) ⇒ Adapter

Returns a new instance of Adapter.



50
51
52
53
54
55
56
 
# File 'lib/async/http/faraday/adapter.rb', line 50

def initialize(*arguments, **options, &block)
	super
	
	@internet = Async::HTTP::Internet.new
	@persistent = PERSISTENT && options.fetch(:persistent, true)
	@timeout = options[:timeout]
end

Instance Method Details

#call(env) ⇒ Object 



62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
 
# File 'lib/async/http/faraday/adapter.rb', line 62

def call(env)
	super
	
	parent = Async::Task.current?
	
	Sync do
		with_timeout do
			response = @internet.call(env[:method].to_s.upcase, env[:url].to_s, env[:request_headers], env[:body] || [])
			
			save_response(env, response.status, response.read, response.headers)
		end
	ensure
		# If we are the top level task, even if we are persistent, we must close the connection:
		if parent.nil? || !@persistent
			@internet.close
		end
	end
	
	return @app.call(env)
rescue Errno::ETIMEDOUT, Async::TimeoutError => e
	raise ::Faraday::TimeoutError, e
rescue OpenSSL::SSL::SSLError => e
	raise ::Faraday::SSLError, e
rescue *CONNECTION_EXCEPTIONS => e
	raise ::Faraday::ConnectionFailed, e
end

#close ⇒ Object 



58
59
60
 
# File 'lib/async/http/faraday/adapter.rb', line 58

def close
	@internet.close
end