class Fluent::EventStream

def repeatable?
  false
end

def to_msgpack_stream
  out = ''
  each {|time,record|
    [time,record].to_msgpack(out)
  }
  out
end