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.



185
186
187
188
 
# File 'lib/httpx/adapters/faraday.rb', line 185

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

Instance Method Details

#connection(env) {|conn| ... } ⇒ Object

from Faraday::Adapter#connection

Yields:

  • (conn) 


222
223
224
225
226
227
 
# File 'lib/httpx/adapters/faraday.rb', line 222

def connection(env)
  conn = build_connection(env)
  return conn unless block_given?

  yield conn
end

#enqueue(request) ⇒ Object 



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

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

#run ⇒ Object 



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

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)
    end
  end
rescue ::HTTPX::TimeoutError => e
  raise Faraday::TimeoutError, e
end