class Af::QThread::MessageHandler
Attributes
thread[R]
Public Class Methods
new(thread)
click to toggle source
# File lib/fiksu-af/q_thread/message_handler.rb, line 5 def initialize(thread) @thread = thread end
run(thread = Thread.current)
click to toggle source
# File lib/fiksu-af/q_thread/message_handler.rb, line 9 def self.run(thread = Thread.current) return new(thread).run end
Public Instance Methods
process_message(message)
click to toggle source
# File lib/fiksu-af/q_thread/message_handler.rb, line 26 def process_message(message) return nil end
process_messages()
click to toggle source
# File lib/fiksu-af/q_thread/message_handler.rb, line 17 def process_messages while true message = thread.read_message break if message.data == :terminate response = process_message(message) message.from.post_data_message(response, thread) end end
run()
click to toggle source
# File lib/fiksu-af/q_thread/message_handler.rb, line 13 def run process_messages end