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.