lib/gearman/worker.rb in xing-gearman-ruby-1.2.0 vs lib/gearman/worker.rb in xing-gearman-ruby-1.3.0

@@ -77,9 +77,25 @@
       req = Util.pack_request(
         :work_status, "#{@handle}\0#{numerator}\0#{denominator}")
       Util.send_request(@socket, req)
       self
     end
+
+    ##
+    # Send data before job completes
+    def send_data(data)
+      req = Util.pack_request(:work_data, "#{@handle}\0#{data}")
+      Util.send_request(@socket, req)
+      self
+    end
+
+    ##
+    # Send a warning explicitly
+    def report_warning(warning)
+      req = Util.pack_request(:work_warning, "#{@handle}\0#{warning}")
+      Util.send_request(@socket, req)
+      self
+    end
   end
 
   ##
   # Create a new worker.
   #