class Protobuf::Rpc::Connectors::EMClient

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