class ActiveSupport::Testing::Parallelization::Server

def record(reporter, result)
  raise DRb::DRbConnError if result.is_a?(DRb::DRbUnknown)
  @in_flight.delete([result.klass, result.name])
  reporter.synchronize do
    reporter.record(result)
  end
end