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

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

Instance Method Summary collapse

Instance Method Details

#call(env) ⇒ Object 



29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/async/http/faraday/adapter.rb', line 29

def call(env)
	super
	
	client = HTTP::Client.new(*endpoints_for(env).to_a)
	
	response = client.send(env[:method], env[:url].request_uri, env[:request_headers], env[:body] || [])
	
	save_response(env, response.status, response.body.read, response.headers)
	
	@app.call env
end

#endpoints_for(env) ⇒ Object 



41
42
43
44
45
46
47
 
# File 'lib/async/http/faraday/adapter.rb', line 41

def endpoints_for(env)
	return to_enum(:endpoints_for, env) unless block_given?
	
	if url = env[:url]
		yield Async::HTTP::Endpoint.new(url)
	end
end