# File lib/resque/scheduler/delaying_extensions.rb, line 114 def next_item_for_timestamp(timestamp) key = "delayed:#{timestamp.to_i}" encoded_item = redis.lpop(key) redis.srem("timestamps:#{encoded_item}", key) item = decode(encoded_item) # If the list is empty, remove it. clean_up_timestamp(key, timestamp) item end