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(app, opts, &block) 13 end
setup_parallel_manager(options = {})
[show source]
# File lib/httpx/adapters/faraday.rb 252 def setup_parallel_manager(options = {}) 253 ParallelManager.new(options) 254 end
Public Instance methods
call(env)
[show source]
# File lib/httpx/adapters/faraday.rb 257 def call(env) 258 super 259 if parallel?(env) 260 handler = env[:parallel_manager].enqueue(env) 261 handler.on_response do |response| 262 if response.is_a?(::HTTPX::Response) 263 save_response(env, response.status, response.body.to_s, response.headers, response.reason) do |response_headers| 264 response_headers.merge!(response.headers) 265 end 266 else 267 env[:error] = response.error 268 save_response(env, 0, "", {}, nil) 269 end 270 end 271 return handler 272 end 273 274 response = connect_and_request(env) 275 save_response(env, response.status, response.body.to_s, response.headers, response.reason) do |response_headers| 276 response_headers.merge!(response.headers) 277 end 278 @app.call(env) 279 end