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