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