6 7 8 9
# File 'lib/sidekiq/web_custom/queue.rb', line 6 def drain(max:) count = [size, max].min Sidekiq::WebCustom::Processor.execute(max: count, queue: self) end