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