class Fluent::ArrayEventStream

def each(&block)
  @entries.each(&block)
  nil
end

def empty?
  @time_array.empty?
end

def initialize(entries)
  @entries = entries
end

def repeatable?
  true
end