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