class Protobuf::Rpc::Connectors::EMClient

def connect(options={})
  options = DEFAULT_OPTIONS.merge(options)
  log_debug "[client-#{self}] Connecting to server: %s" % options.inspect
  EM.connect(options[:host], options[:port], self, options)
end