def request(env)
req = ::Typhoeus::Request.new env[:url].to_s,
:method => env[:method],
:body => env[:body],
:headers => env[:request_headers],
:disable_ssl_peer_verification => (env[:ssl] && !env[:ssl].fetch(:verify, true))
configure_ssl req, env
configure_proxy req, env
configure_timeout req, env
req.on_complete do |resp|
if resp.timed_out?
if parallel?(env)
else
raise Faraday::Error::TimeoutError, "request timed out"
end
end
save_response(env, resp.code, resp.body) do |response_headers|
response_headers.parse resp.headers
end
env[:response].finish(env) if parallel?(env)
end
req
end