Method: Faraday::Adapter::HTTPX::ParallelManager#run

Defined in:

lib/httpx/adapters/faraday.rb

#run ⇒ Object

# File 'lib/httpx/adapters/faraday.rb', line 209

def run
  return unless @handlers.last

  env = @handlers.last.env

  connect(env) do |session|
    requests = @handlers.map { |handler| session.build_request(*build_request(handler.env)) }

    if env.request.stream_response?
      requests.each do |request|
        request.response_on_data = env.request.on_data
      end
    end

    responses = session.request(*requests)
    Array(responses).each_with_index do |response, index|
      handler = @handlers[index]
      handler.on_response.call(response)
      handler.on_complete.call(handler.env) if handler.on_complete
    end
  end
end