module SlowEnumeratorTools::Bufferer
Public Class Methods
buffer(enum, size)
click to toggle source
# File lib/slow_enumerator_tools/bufferer.rb, line 5 def self.buffer(enum, size) queue = SizedQueue.new(size) thread = SlowEnumeratorTools::Util.gen_collector_thread(enum, queue) gen_enumerator(queue, thread) end
gen_enumerator(queue, collector_thread)
click to toggle source
# File lib/slow_enumerator_tools/bufferer.rb, line 11 def self.gen_enumerator(queue, collector_thread) Enumerator.new do |y| loop do elem = queue.pop if SlowEnumeratorTools::Util::STOP_OK.equal?(elem) break elsif SlowEnumeratorTools::Util::STOP_ERR.equal?(elem) raise queue.pop end y << elem end collector_thread.join end.lazy end