module Protobuf
  module Rpc
    class EventedRunner

      def initialize(options)
        @options = options
      end

      def run
        # 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
        yield if block_given?

        ::EM.reactor_running? ? ::EM.reactor_thread.join : ::EM.run
      end

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

    end
  end
end