module EventMachine::Synchrony::AMQP

def sync &blk
  fiber = Fiber.current
  blk.call(fiber)
  Fiber.yield
end

def sync_cb fiber
  lambda do |*args|
    if fiber == Fiber.current
      return *args
    else
      fiber.resume(*args)
    end
  end
end