lib/typhoeus/hydra/runnable.rb in typhoeus-0.6.8 vs lib/typhoeus/hydra/runnable.rb in typhoeus-0.6.9

@@ -9,16 +9,10 @@
       # @example Start hydra run.
       #   hydra.run
       #
       # @return [ Symbol ] Return value from multi.perform.
       def run
-        number_requests = 0
-        loop do
-          break if number_requests == max_concurrency || queued_requests.empty?
-          number_requests += queued_requests.pop(max_concurrency).map do |request|
-            add(request)
-          end.size
-        end
+        dequeue_many
         multi.perform
       end
     end
   end
 end