class OTerm::Server

Attributes

acceptThread[RW]
debug[RW]
listeners[RW]
stop[RW]

Public Class Methods

new(executor, port=6060, debug=false) click to toggle source
# File lib/oterm/server.rb, line 13
def initialize(executor, port=6060, debug=false)
  @debug = debug
  @stop = false
  @listeners = []
  @acceptThread = Thread.start() do
    server = TCPServer.new(port)
    while !stop do
      Thread.start(server.accept()) do |con|
        @listeners << Listener.new(self, con, executor)
      end
    end
  end
end

Public Instance Methods

join() click to toggle source
# File lib/oterm/server.rb, line 35
def join()
  @acceptThread.join()
end
remove_listener(listener) click to toggle source
# File lib/oterm/server.rb, line 31
def remove_listener(listener)
  @listeners.delete(listener)
end
shutdown() click to toggle source
# File lib/oterm/server.rb, line 27
def shutdown()
  @acceptThread.exit()
end