EventMachine adapter is useful for either asynchronous requests when in EM reactor loop or for making parallel requests in synchronous code.
# File lib/faraday/adapter/em_http.rb, line 68 def call(env) super perform_request env @app.call env end
# File lib/faraday/adapter/em_http.rb, line 125 def error_message(client) client.error or "request failed" end
# File lib/faraday/adapter/em_http.rb, line 143 def parallel?(env) !!env[:parallel_manager] end
# File lib/faraday/adapter/em_http.rb, line 74 def perform_request(env) if parallel?(env) manager = env[:parallel_manager] manager.add { perform_single_request(env). callback { env[:response].finish(env) } } else unless EventMachine.reactor_running? error = nil # start EM, block until request is completed EventMachine.run do perform_single_request(env). callback { EventMachine.stop }. errback { |client| error = error_message(client) EventMachine.stop } end raise_error(error) if error else # EM is running: instruct upstream that this is an async request env[:parallel_manager] = true perform_single_request(env). callback { env[:response].finish(env) }. errback { # TODO: no way to communicate the error in async mode raise NotImplementedError } end end rescue EventMachine::Connectify::CONNECTError => err if err.message.include?("Proxy Authentication Required") raise Error::ConnectionFailed, %{407 "Proxy Authentication Required "} else raise Error::ConnectionFailed, err end end
TODO: reuse the connection to support pipelining
# File lib/faraday/adapter/em_http.rb, line 114 def perform_single_request(env) req = EventMachine::HttpRequest.new(env[:url], connection_config(env)) req.setup_request(env[:method], request_config(env)).callback { |client| save_response(env, client.response_header.status, client.response) do |resp_headers| client.response_header.each do |name, value| resp_headers[name.to_sym] = value end end } end
# File lib/faraday/adapter/em_http.rb, line 129 def raise_error(msg) errklass = Faraday::Error::ClientError if msg == Errno::ETIMEDOUT errklass = Faraday::Error::TimeoutError msg = "request timed out" elsif msg == Errno::ECONNREFUSED errklass = Faraday::Error::ConnectionFailed msg = "connection refused" elsif msg == "connection closed by server" errklass = Faraday::Error::ConnectionFailed end raise errklass, msg end
Generated with the Darkfish Rdoc Generator 2.