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 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
Generated with the Darkfish Rdoc Generator 2.