Included modules
Classes and Modules
Public Class methods
new(app = nil, opts = {}, &block)
[show source]
# File lib/httpx/adapters/faraday.rb 10 def initialize(app = nil, opts = {}, &block) 11 @connection = @bind = nil 12 super 13 end
setup_parallel_manager(options = {})
[show source]
# File lib/httpx/adapters/faraday.rb 242 def setup_parallel_manager(options = {}) 243 ParallelManager.new(options) 244 end
Public Instance methods
call(env)
[show source]
# File lib/httpx/adapters/faraday.rb 247 def call(env) 248 super 249 if parallel?(env) 250 handler = env[:parallel_manager].enqueue(env) 251 handler.on_response do |response| 252 if response.is_a?(::HTTPX::Response) 253 save_response(env, response.status, response.body.to_s, response.headers, response.reason) do |response_headers| 254 response_headers.merge!(response.headers) 255 end 256 else 257 env[:error] = response.error 258 save_response(env, 0, "", {}, nil) 259 end 260 end 261 return handler 262 end 263 264 response = connect_and_request(env) 265 save_response(env, response.status, response.body.to_s, response.headers, response.reason) do |response_headers| 266 response_headers.merge!(response.headers) 267 end 268 @app.call(env) 269 end