Coolio::IO
# File lib/fluent/plugin/in_forward.rb, line 193 def initialize(io, callback) super(io) @io = io @callback = callback end
# File lib/fluent/plugin/in_forward.rb, line 199 def on_readable begin msg, addr = @io.recvfrom(1024) rescue Errno::EAGAIN, Errno::EWOULDBLOCK, Errno::EINTR return end host = addr[3] port = addr[1] @callback.call(host, port, msg) rescue # TODO log? end
[Validate]
Generated with the Darkfish Rdoc Generator 2.