lib/rainbows/rev/master.rb in rainbows-0.96.0 vs lib/rainbows/rev/master.rb in rainbows-0.97.0

- old
+ new

@@ -1,26 +1,21 @@ # -*- encoding: binary -*- # :enddoc: require 'rainbows/rev' -module Rainbows +class Rainbows::Rev::Master < Rev::AsyncWatcher - module Rev - class Master < ::Rev::AsyncWatcher + def initialize(queue) + super() + @queue = queue + end - def initialize(queue) - super() - @queue = queue - end + def <<(output) + @queue << output + signal + end - def <<(output) - @queue << output - signal - end - - def on_signal - client, response = @queue.pop - client.response_write(response) - end - end + def on_signal + client, response = @queue.pop + client.response_write(response) end end