class Fluent::Counter::BaseSocket

def on_message(data)
  raise NotImplementedError
end

def on_read(data)
  msgpack_unpacker.feed_each(data) do |d|
    on_message d
  end
end

def pack(data)
  msgpack_packer.pack(data)
end

def packed_write(data)
  write pack(data)
end