module SlowEnumeratorTools::Util
Constants
- STOP_ERR
- STOP_OK
Public Class Methods
gen_collector_thread(enum, queue)
click to toggle source
# File lib/slow_enumerator_tools/util.rb, line 8 def self.gen_collector_thread(enum, queue) Thread.new do begin enum.each { |e| queue << e } queue << STOP_OK rescue StandardError => e queue << STOP_ERR queue << e end end end