lib/ci/queue/static.rb in ci-queue-0.16.0 vs lib/ci/queue/static.rb in ci-queue-0.17.0

- old
+ new

@@ -1,5 +1,7 @@ +# frozen_string_literal: true + module CI module Queue class Static include Common class << self @@ -46,10 +48,10 @@ def size @queue.size end def poll - while !config.circuit_breaker.open? && test = @queue.shift + while !config.circuit_breakers.any?(&:open?) && test = @queue.shift yield index.fetch(test) end end def exhausted?