lib/async/container/threaded.rb in async-container-0.13.0 vs lib/async/container/threaded.rb in async-container-0.14.0
- old
+ new
@@ -94,14 +94,14 @@
@threads << thread
return self
end
- def wait
+ def wait(forever = false)
@threads.each(&:join)
@threads.clear
- return nil
+ sleep if forever
rescue Interrupt
# Graceful exit.
end
# Gracefully shut down all reactors.