socket_channel_increment.rb

class Handler < EM::Connection
  def initialize(*args)
    @channel = args[0]
    @counter = 0
    super *args
  end

  def receive_data(data)
    if data && data.size > 0
      @counter += 1
      @channel.push(data)
    end
  end
end