Sha256: e30e7a04b8e4f650bd10d58b1837b2db1a5bb676e83cac6e81543f71d463059b
Contents?: true
Size: 724 Bytes
Versions: 2
Compression:
Stored size: 724 Bytes
Contents
require "em-jack" # WANT: namespaced under EventMachine.. would be nice :-) # NOTE: no need for "pooling" since Beanstalk supports pipelining module EMJack class Connection alias :ause :use def use(tube, &blk) return if @used_tube == tube f = Fiber.current # WANT: per command errbacks, would be nice, instead of one global # errback = Proc.new {|r| f.resume(r) } on_error {|r| f.resume(r)} @used_tube = tube @conn.send(:use, tube) # WANT: Add conditional on add_deferrable to either accept two procs, or a single block # .. two procs = callback, errback add_deferrable { |r| f.resume(r) } Fiber.yield end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
em-synchrony-0.1.4 | lib/em-synchrony/em-jack.rb |
em-synchrony-0.1.2 | lib/em-synchrony/em-jack.rb |