Class: Faraday::Adapter::HTTPX::ParallelManager

Inherits:
Object
  • Object
show all
Includes:
RequestMixin
Defined in:
lib/httpx/adapters/faraday.rb

Defined Under Namespace

Classes: ResponseHandler

Instance Method Summary collapse

Methods included from RequestMixin

#build_connection, #close

Constructor Details

#initialize(options) ⇒ ParallelManager

Returns a new instance of ParallelManager.



189
190
191
192
 
# File 'lib/httpx/adapters/faraday.rb', line 189

def initialize(options)
  @handlers = []
  @connection_options = options
end

Instance Method Details

#enqueue(request) ⇒ Object 



194
195
196
197
198
 
# File 'lib/httpx/adapters/faraday.rb', line 194

def enqueue(request)
  handler = ResponseHandler.new(request)
  @handlers << handler
  handler
end

#run ⇒ Object 



200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
 
# File 'lib/httpx/adapters/faraday.rb', line 200

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)
    end
  end
end