Refactor.

lib/beanstalk-client/connection.rb

@@ -58,14 +58,10 @@ def yput(obj, pri=65536, delay=0, ttr=120)
 
     def peek()
       interact("peek\r\n", :job)
-    rescue NotFoundError
-      nil
     end
 
     def peek_job(id)
       interact("peek #{id}\r\n", :job)
-    rescue NotFoundError
-      nil
     end
 
     def reserve()
@@ -150,7 +146,7 @@ def interact(cmd, rfmt)
       raise WaitingForJobError if @waiting
       @socket.write(cmd)
       return read_yaml('OK') if rfmt == :yaml
-      return Job.new(@jptr, *read_job('FOUND')) if rfmt == :job
+      return found_job if rfmt == :job
       check_resp(*rfmt)
     end
 
@@ -169,6 +165,12 @@ def check_resp(*words)
       vals
     end
 
+    def found_job()
+      Job.new(@jptr, *read_job('FOUND'))
+    rescue NotFoundError
+      nil
+    end
+
     def read_job(word)
       id, bytes = check_resp(word).map{|s| s.to_i}
       body = read_bytes(bytes)