lib/nonnative/pool.rb in nonnative-1.26.0 vs lib/nonnative/pool.rb in nonnative-1.27.0
- old
+ new
@@ -44,11 +44,9 @@
types << type
pids << type.send(type_method)
threads << Thread.new { port.send(port_method) }
end
- ThreadsWait.all_waits(*threads)
-
ports = threads.map(&:value)
yield_results(types, pids, ports, &block)
end