class Pluggaloid::Stream::Merge
Public Class Methods
new(*sources)
click to toggle source
# File lib/pluggaloid/stream.rb, line 74 def initialize(*sources) @sources = sources end
Public Instance Methods
each(&block)
click to toggle source
# File lib/pluggaloid/stream.rb, line 78 def each(&block) fiber = Fiber.new do loop do block.call(Fiber.yield) end end fiber.resume @sources.each do |source| source.each(&fiber.method(:resume)) end self end