class Fluent::Counter::Handler
Public Class Methods
new(io, on_message)
click to toggle source
Calls superclass method
# File lib/fluent/counter/server.rb, line 262 def initialize(io, on_message) super(io) @on_message = on_message end
Public Instance Methods
on_message(data)
click to toggle source
# File lib/fluent/counter/server.rb, line 267 def on_message(data) res = @on_message.call(data) packed_write res if res end