Merge branch 'master' of git://github.com/mperham/em-jack

README.rdoc

@@ -78,3 +78,4 @@ contact me by email at dj2 at everburning dot com.
 Charles Melbye (cmelbye)
 Peter Kieltyka (pkieltyka)
 Martyn Loughran (mloughran)
+Mike Perham (mperham)

lib/em-jack/connection.rb

@@ -43,6 +43,25 @@ def initialize(opts = {})
       end
     end
 
+    def fiber!
+      eigen = (class << self
+       self
+      end)
+      eigen.instance_eval do
+        %w(use reserve ignore watch peek stats list delete touch bury kick pause release put).each do |meth|
+          alias_method :"a#{meth}", meth.to_sym
+          define_method(meth.to_sym) do |*args|
+            fib = Fiber.current
+            ameth = :"a#{meth}"
+            p [ameth, *args]
+            proc = lambda { |*result| fib.resume(*result) }
+            send(ameth, *args, &proc)
+            Fiber.yield
+          end
+        end
+      end
+    end
+
     def use(tube, &blk)
       return if @used_tube == tube
 

spec/fiber_spec.rb

@@ -0,0 +1,26 @@
+require 'rubygems'
+require 'spec'
+
+require 'em-jack'
+require 'fiber'
+
+describe EMJack::Connection do
+  it "should process live messages" do
+    EM.run do
+      EM.add_timer(10) { EM.stop }
+
+      Fiber.new do
+        bean = EMJack::Connection.new
+        bean.fiber!
+
+        bean.put("hello!")
+        job = bean.reserve
+        job.body.should == "hello!"
+        job.delete
+
+        p bean.stats
+        EM.stop
+      end.resume
+    end
+  end
+end