chunk.extend(ChunkEventStreamer)
=> chunk.each{|time, record| ... }
# File lib/fluent/event.rb, line 321 def each(&block) open do |io| msgpack_unpacker(io).each(&block) end nil end
# File lib/fluent/event.rb, line 329 def to_msgpack_stream(time_int: false) # time_int is always ignored because data is already packed and written in chunk read end