class Fluent::MultiEventStream

def add(time, record)
  @time_array << time
  @record_array << record
end

def each(&block)
  time_array = @time_array
  record_array = @record_array
  for i in 0..time_array.length-1
    block.call(time_array[i], record_array[i])
  end
  nil
end

def empty?
  @time_array.empty?
end

def initialize
  @time_array = []
  @record_array = []
end

def repeatable?
  true
end