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