module Fluent::ChunkMessagePackEventStreamer

def each(&block)
  open do |io|
    msgpack_unpacker(io).each(&block)
  end
  nil
end

def to_msgpack_stream(time_int: false)
  # time_int is always ignored because data is already packed and written in chunk
  read
end