class Fluent::Counter::Handler

def initialize(io, on_message)
  super(io)
  @on_message = on_message
end

def on_message(data)
  res = @on_message.call(data)
  packed_write res if res
end