socket_with_stats.rb

module SocketWithStats
  attr_reader :read_bytes
  def read *args
    @read_bytes ||= 0.bytes
    got = super
    @read_bytes += args.first
    return got
  end
end

TCPSocket.open(host,port) do |socket|
  socket.extend SocketWithStats
  Thread.new { loop {puts socket.read_bytes} }
  socket.gets
end