# File lib/fluent/event.rb, line 278 def initialize(data, cached_unpacker = nil, size = 0, unpacked_times: nil, unpacked_records: nil) super @decompressed_data = nil @compressed_data = data end
# File lib/fluent/event.rb, line 294 def each(&block) ensure_decompressed! super end
# File lib/fluent/event.rb, line 284 def empty? ensure_decompressed! super end
# File lib/fluent/event.rb, line 289 def ensure_unpacked! ensure_decompressed! super end
# File lib/fluent/event.rb, line 304 def to_compressed_msgpack_stream(time_int: false) # time_int is always ignored because @data is always packed binary in this class @compressed_data end
# File lib/fluent/event.rb, line 299 def to_msgpack_stream(time_int: false) ensure_decompressed! super end
# File lib/fluent/event.rb, line 311 def ensure_decompressed! return if @decompressed_data @data = @decompressed_data = decompress(@data) end