class Rumid::TcpServer

Extended GServer, baked to work with Rumid::Server servers

Public Class Methods

new(port, protocol_server, *args) click to toggle source

@param port [Integer] port to be listened by the server @param protocol_server [Rumid::Server] klass the extended Server class

Calls superclass method
# File lib/rumid/tcp_server.rb, line 8
def initialize(port, protocol_server, *args)
  super(port, *args)
  @protocol_server = protocol_server
end

Public Instance Methods

serve(session) click to toggle source

Overriden Gserver#serve function. @note Typicaly you should not call this method @param session [IO] I/O stream from TCP connection

# File lib/rumid/tcp_server.rb, line 17
def serve(session)
  loop{
    begin
      @protocol_server.new.serve(session)
    rescue Rumid::Errors::NotValidRequestError
      log "Error in validation occured!"
    end
  }
end