multi.rb

# Acts like an array and receives futures. Will yield them as
# they become ready.

class HackedMultiplexer
  include Celluloid
  include Enumerable

  def initialize
    @not_ready = []
  end

  def push(obj)
    @not_ready.push(obj)
  end
  alias_method :<<, :push

  def each(&blk)
    loop do
      ready = @not_ready.select { |future| future.ready? }
      @not_ready -= ready

      ready.each { |future| yield(future) }
      
      break if @not_ready.empty?
    end
  end
end