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