class Protobuf::Rpc::EventedRunner

def self.run(options)
  # Startup and run the rpc server
  ::EventMachine.schedule do
    ::EventMachine.start_server(options[:host], options[:port], ::Protobuf::Rpc::Evented::Server)
  end
  # Join or start the reactor
eld if block_given?
  ::EM.reactor_running? ? ::EM.reactor_thread.join : ::EM.run
end

def self.stop
  ::EventMachine.stop_event_loop if ::EventMachine.reactor_running?
end