gistfile1.txt

require 'socket'

require 'rubygems'
require 'nokogiri'

PORT = rand(65535 - 1024) + 1024

sthread = Thread.new {
  s = TCPServer.new(PORT).accept
  s.write('<foo>')
  10.times {
    s.write('<test>')
    s.write('DATA' * 1000)
    s.write('</test>')
  }
  sleep 30
  s.write('</foo>')
  s.close
}

c = TCPSocket.new('', PORT)

Nokogiri::XML::Reader.from_io(c).each { |node|
  puts node.name
}

sthread.join


Nokogiri::XML::Reader.from_io(c).each { |node|
  puts node.name
}

sthread.join