class EventMachine::Synchrony::AMQP::Channel

def initialize(*params, &block)
  f = Fiber.current
  super(*params, &EM::Synchrony::AMQP.sync_cb(f))
  channel, open_ok = Fiber.yield
  raise Error.new unless open_ok.is_a?(::AMQ::Protocol::Channel::OpenOk)
  channel
end