lib/resque_spec/ext.rb in resque_spec-0.12.0 vs lib/resque_spec/ext.rb in resque_spec-0.12.1

@@ -30,10 +30,11 @@
   end
 
   alias :enqueue_without_resque_spec :enqueue
   alias :enqueue_to_without_resque_spec :enqueue_to if Resque.respond_to? :enqueue_to
   alias :reserve_without_resque_spec :reserve
+  alias :peek_without_resque_spec :peek
 
   def enqueue(klass, *args)
     return enqueue_without_resque_spec(klass, *args) if ResqueSpec.disable_ext
 
     enqueue_to(queue_from_class(klass), klass, *args)
@@ -49,9 +50,16 @@
     else
       return if run_before_enqueue(klass, *args)
       Job.create(queue, klass, *args)
       run_after_enqueue(klass, *args)
       true
+    end
+  end
+
+  def peek(queue, start = 0, count = 1)
+    return peek_without_resque_spec(queue, start, count) if ResqueSpec.disable_ext
+    ResqueSpec.peek(queue, start, count).map do |job|
+      job.inject({}) { |a, (k, v)| a[k.to_s] = v; a }
     end
   end
 
   def reserve(queue_name)
     return reserve_without_resque_spec(queue_name) if ResqueSpec.disable_ext