Parent

Methods

Faraday::Adapter::EMSynchrony::ParallelManager

Public Instance Methods

add(request, method, *args, &block) click to toggle source

Add requests to queue. The `request` argument should be a `EM::HttpRequest` object.

# File lib/faraday/adapter/em_synchrony/parallel_manager.rb, line 8
def add(request, method, *args, &block)
  queue << {
    :request => request,
    :method => method,
    :args => args,
    :block => block
  }
end
run() click to toggle source

Run all requests on queue with `EM::Synchrony::Multi`, wrapping it in a reactor and fiber if needed.

# File lib/faraday/adapter/em_synchrony/parallel_manager.rb, line 19
def run
  result = nil
  if !EM.reactor_running?
    EM.run {
      Fiber.new do
        result = perform
        EM.stop
      end.resume
    }
  else
    result = perform
  end
  result
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.