class Fluent::ArrayEventStream

def dup
  entries = @entries.map{ |time, record| [time, record.dup] }
  ArrayEventStream.new(entries)
end