Class: Faraday::Adapter::HTTPX
- Inherits:
-
Faraday::Adapter
- Object
- Faraday::Adapter
- Faraday::Adapter::HTTPX
- Includes:
- RequestMixin
- Defined in:
- lib/httpx/adapters/faraday.rb
Defined Under Namespace
Modules: RequestMixin Classes: ParallelManager, Session
Class Method Summary collapse
Instance Method Summary collapse
- #call(env) ⇒ Object
-
#initialize(app) ⇒ HTTPX
constructor
A new instance of HTTPX.
Constructor Details
Class Method Details
.setup_parallel_manager ⇒ Object
139 140 141 |
# File 'lib/httpx/adapters/faraday.rb', line 139 def setup_parallel_manager ParallelManager.new end |
Instance Method Details
#call(env) ⇒ Object
149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 |
# File 'lib/httpx/adapters/faraday.rb', line 149 def call(env) if parallel?(env) handler = env[:parallel_manager].enqueue(env) handler.on_response do |response| save_response(env, response.status, response.body, response.headers, response.reason) do |response_headers| response_headers.merge!(response.headers) end end return handler end = build_request(env) = { connect_timeout: env.request.open_timeout, operation_timeout: env.request.timeout, }.reject { |_, v| v.nil? } = { ssl: env.ssl, timeout: , } = { uri: env.request.proxy } session = @session.with() session = session.plugin(:proxy).with_proxy() if env.request.proxy response = session.__send__(*) response.raise_for_status unless response.is_a?(::HTTPX::Response) save_response(env, response.status, response.body, response.headers, response.reason) do |response_headers| response_headers.merge!(response.headers) end @app.call(env) rescue OpenSSL::SSL::SSLError => err raise Error::SSLError, err rescue Errno::ECONNABORTED, Errno::ECONNREFUSED, Errno::ECONNRESET, Errno::EHOSTUNREACH, Errno::EINVAL, Errno::ENETUNREACH, Errno::EPIPE => err raise Error::ConnectionFailed, err end |