Class: Faraday::Adapter::EMSynchrony
- Inherits:
-
Faraday::Adapter
- Object
- Middleware
- Faraday::Adapter
- Faraday::Adapter::EMSynchrony
- Defined in:
- lib/faraday/adapter/em_synchrony.rb
Constant Summary
Constants inherited from Faraday::Adapter
Instance Method Summary collapse
Methods inherited from Faraday::Adapter
Methods included from Faraday::AutoloadHelper
#all_loaded_constants, #autoload_all, #load_autoloaded_constants, #lookup_module, #register_lookup_modules
Methods inherited from Middleware
dependency, #initialize, loaded?, setup_parallel_manager
Constructor Details
This class inherits a constructor from Faraday::Middleware
Instance Method Details
#call(env) ⇒ Object
9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
# File 'lib/faraday/adapter/em_synchrony.rb', line 9 def call(env) super request = EventMachine::HttpRequest.new(URI::parse(env[:url].to_s)) = {:head => env[:request_headers]} [:ssl] = env[:ssl] if env[:ssl] if env[:body] if env[:body].respond_to? :read [:body] = env[:body].read else [:body] = env[:body] end end if req = env[:request] if proxy = req[:proxy] uri = Addressable::URI.parse(proxy[:uri]) [:proxy] = { :host => uri.host, :port => uri.inferred_port } if proxy[:username] && proxy[:password] [:proxy][:authorization] = [proxy[:username], proxy[:password]] end end # only one timeout currently supported by em http request if req[:timeout] or req[:open_timeout] [:timeout] = [req[:timeout] || 0, req[:open_timeout] || 0].max end end client = nil block = lambda { request.send env[:method].to_s.downcase.to_sym, } if !EM.reactor_running? EM.run { Fiber.new do client = block.call EM.stop end.resume } else client = block.call end save_response(env, client.response_header.status, client.response) do |response_headers| client.response_header.each do |name, value| response_headers[name.to_sym] = value end end @app.call env rescue Errno::ECONNREFUSED raise Error::ConnectionFailed, $! end |