class TurboTests::Runner

def start_copy_thread(src, dst)
  Thread.new do
    loop do
      msg = src.readpartial(4096)
    rescue EOFError
      src.close
      break
    else
      dst.write(msg)
    end
  end
end