lib/rainbows/rev/master.rb

   1 # -*- encoding: binary -*-
   2 require 'rainbows/rev'
   3
   4 RUBY_VERSION =~ %r{\A1\.8} && ::Rev::VERSION < "0.3.2" and
   5   warn "Rainbows::RevThreadSpawn + Rev (< 0.3.2)" \
   6        " does not work well under Ruby 1.8"
   7
   8 module Rainbows
   9
  10   module Rev
  11     class Master < ::Rev::AsyncWatcher
  12
  13       def initialize(queue)
  14         super()
  15         @queue = queue
  16       end
  17
  18       def <<(output)
  19         @queue << output
  20         signal
  21       end
  22
  23       def on_signal
  24         client, response = @queue.pop
  25         client.response_write(response)
  26       end
  27     end
  28   end
  29 end