class ParallelTests::Test::Runner

def capture_output(out, env, options={})
  result = ""
  loop do
    begin
      read = out.readpartial(1000000) # read whatever chunk we can get
      if Encoding.default_internal
        read = read.force_encoding(Encoding.default_internal)
      end
      result << read
      unless options[:serialize_stdout]
        message = read
        message = "[TEST GROUP #{env['TEST_ENV_NUMBER']}] #{message}" if options[:prefix_output_with_test_env_number]
        $stdout.print message
        $stdout.flush
      end
    end
  end rescue EOFError
  result
end