Class: Faraday::Adapter::EMSynchrony
- Inherits:
-
Faraday::Adapter
- Object
- Faraday::Adapter
- Faraday::Adapter::EMSynchrony
- Includes:
- Faraday::Adapter::EMHttp::Options
- Defined in:
- lib/faraday/adapter/em_synchrony.rb,
lib/faraday/adapter/em_synchrony/parallel_manager.rb
Overview
EventMachine Synchrony adapter.
Defined Under Namespace
Classes: ParallelManager
Constant Summary
Constants inherited from Faraday::Adapter
Instance Attribute Summary
Attributes included from DependencyLoader
Attributes included from Parallelism
Class Method Summary collapse
Instance Method Summary collapse
Methods included from Faraday::Adapter::EMHttp::Options
#configure_compression, #configure_proxy, #configure_socket, #configure_ssl, #configure_timeout, #connection_config, #read_body, #request_config, #request_options
Methods inherited from Faraday::Adapter
Methods included from MiddlewareRegistry
#fetch_middleware, #load_middleware, #lookup_middleware, #middleware_mutex, #register_middleware, #unregister_middleware
Methods included from DependencyLoader
#dependency, #inherited, #loaded?, #new
Methods included from Parallelism
#inherited, #supports_parallel?
Methods included from Faraday::AutoloadHelper
#all_loaded_constants, #autoload_all, #load_autoloaded_constants
Constructor Details
This class inherits a constructor from Faraday::Adapter
Class Method Details
.setup_parallel_manager(_options = nil) ⇒ ParallelManager
20 21 22 |
# File 'lib/faraday/adapter/em_synchrony.rb', line 20 def self.setup_parallel_manager( = nil) ParallelManager.new end |
Instance Method Details
#call(env) ⇒ Object
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 64 |
# File 'lib/faraday/adapter/em_synchrony.rb', line 24 def call(env) super request = create_request(env) http_method = env[:method].to_s.downcase.to_sym if env[:parallel_manager] # Queue requests for parallel execution. execute_parallel_request(env, request, http_method) else # Execute single request. execute_single_request(env, request, http_method) end @app.call env rescue Errno::ECONNREFUSED raise Faraday::ConnectionFailed, $ERROR_INFO rescue EventMachine::Connectify::CONNECTError => e if e..include?('Proxy Authentication Required') raise Faraday::ConnectionFailed, %(407 "Proxy Authentication Required") end raise Faraday::ConnectionFailed, e rescue Errno::ETIMEDOUT => e raise Faraday::TimeoutError, e rescue RuntimeError => e if e. == 'connection closed by server' raise Faraday::ConnectionFailed, e end raise Faraday::TimeoutError, e if e..include?('timeout error') raise rescue StandardError => e if defined?(OpenSSL) && e.is_a?(OpenSSL::SSL::SSLError) raise Faraday::SSLError, e end raise end |
#create_request(env) ⇒ Object
66 67 68 69 70 71 |
# File 'lib/faraday/adapter/em_synchrony.rb', line 66 def create_request(env) EventMachine::HttpRequest.new( Utils::URI(env[:url].to_s), connection_config(env).merge(@connection_options) ) end |