# File lib/resque/scheduler/delaying_extensions.rb, line 186 def find_delayed_selection(klass = nil, &block) raise ArgumentError, 'Please supply a block' unless block_given? timestamps = redis.zrange(:delayed_queue_schedule, 0, -1) # Beyond 100 there's almost no improvement in speed found = timestamps.each_slice(100).map do |ts_group| jobs = redis.pipelined do |r| ts_group.each do |ts| r.lrange("delayed:#{ts}", 0, -1) end end jobs.flatten.select do |payload| payload_matches_selection?(decode(payload), klass, &block) end end found.flatten end