Method: Fluent::CompressedMessagePackEventStream#initialize

Defined in:
lib/fluent/event.rb

#initialize(data, cached_unpacker = nil, size = 0, unpacked_times: nil, unpacked_records: nil, compress: :gzip) ⇒ CompressedMessagePackEventStream

Returns a new instance of CompressedMessagePackEventStream.



271
272
273
274
275
276
 
# File 'lib/fluent/event.rb', line 271

def initialize(data, cached_unpacker = nil, size = 0, unpacked_times: nil, unpacked_records: nil, compress: :gzip)
  super(data, cached_unpacker, size, unpacked_times: unpacked_times, unpacked_records: unpacked_records)
  @decompressed_data = nil
  @compressed_data = data
  @type = compress
end