method
shutdown
v8.0.0 -
Show latest stable
- Class:
ActiveSupport::Testing::Parallelization::Server
shutdown()public
No documentation available.
# File activesupport/lib/active_support/testing/parallelization/server.rb, line 59
def shutdown
# Wait for initial queue to drain
while @queue.length != 0
sleep 0.1
end
@queue.close
# Wait until all workers have finished
while active_workers?
sleep 0.1
end
@in_flight.values.each do |(klass, name, reporter)|
result = Minitest::Result.from(klass.new(name))
error = RuntimeError.new("result not reported")
error.set_backtrace([""])
result.failures << Minitest::UnexpectedError.new(error)
reporter.synchronize do
reporter.record(result)
end
end
end