Lazy enumeration in parallel

gistfile1.txt

#!/usr/bin/env rbx

require 'pp'

input  = (0 .. 10).to_enum.lazy

enums   = [input]
threads = []

threads << Thread.new(enums[0]) do |enum|
  enums[1] = Enumerator.new do |yielder|
    enum.each { |e| yielder << (e + 1) }
  end.lazy
end

threads << Thread.new(enums[1]) do |enum|
  enums[2] = Enumerator.new do |yielder|
    enum.each { |e| yielder << (e + 1) }
  end.lazy
end

enums.last.each { |e| p e }

threads.each { |t| t.join }