lib/lwes/listener.rb

   1 #
   2 # This class is only supported on Ruby 1.9
   3 #
   4 #   listener = LWES::Listener.new :address => "224.1.1.11", :port => 12345
   5 #   listener.each do |event|
   6 #     p event
   7 #   end
   8 #
   9 class LWES::Listener
  10
  11   # we disallow dup-ing objects since GC could double-free otherwise
  12   def dup
  13     self
  14   end
  15
  16   alias clone dup
  17
  18   # processes each LWES::Event object as it is received, yielding
  19   # the LWES::Event to a given block
  20   def each
  21     begin
  22       yield recv
  23     rescue Errno::EINTR
  24     end while true
  25     self
  26   end
  27 end