class Fluent::Counter::Connection

def initialize(io, on_message)
  super(io)
  @connection = false
  @buffer = ''
  @on_message = on_message
end