Sha256: 695236a9c3c7645ddafaec21ef1eded66d73e98e3bdd57576272f01392d4b7f1
Contents?: true
Size: 562 Bytes
Versions: 7
Compression:
Stored size: 562 Bytes
Contents
module Af::QThread
class MessageHandler
attr_reader :thread
def initialize(thread)
@thread = thread
end
def self.run(thread = Thread.current)
return new(thread).run
end
def run
process_messages
end
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
def process_message(message)
return nil
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems