Method: Sidekiq::JobSet#pop_each

Defined in:
lib/sidekiq/api.rb

#pop_each ⇒ Object 



761
762
763
764
765
766
767
768
769
 
# File 'lib/sidekiq/api.rb', line 761

def pop_each
  Sidekiq.redis do |c|
    size.times do
      data, score = c.zpopmin(name, 1)&.first
      break unless data
      yield data, score
    end
  end
end