Method: Hope::Engine#on_readable

Defined in:
lib/hope/engine.rb

#on_readable(socket, messages) ⇒ Object 



51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
 
# File 'lib/hope/engine.rb', line 51

def on_readable(socket, messages)
  puts "Received event from #{socket}"
  @received += 1
  src_name, msg = messages.map(&:copy_out_string)
  if src = self.register_source(src_name)
    evts = src.parse(msg)
    
    Array(evts).map do |e| 
      puts ">> sendEvent: #{e.inspect}"
      self.sendEvent(e)
    end
  else
    puts "Error: SOURCE #{src_name}, not registered !"
  end
end