module EventMachine::Synchrony::AMQP
Public Class Methods
sync(&blk)
click to toggle source
# File lib/em-synchrony/amqp.rb, line 14 def sync &blk fiber = Fiber.current blk.call(fiber) Fiber.yield end
sync_cb(fiber)
click to toggle source
# File lib/em-synchrony/amqp.rb, line 20 def sync_cb fiber lambda do |*args| if fiber == Fiber.current return *args else fiber.resume(*args) end end end