Method: Fluent::Plugin::Buffer::Chunk::Decompressable#read

Defined in:
lib/fluent/plugin/buffer/chunk.rb

#read(**kwargs) ⇒ Object



219
220
221
222
223
224
225
# File 'lib/fluent/plugin/buffer/chunk.rb', line 219

def read(**kwargs)
  if kwargs[:compressed] == :gzip
    super
  else
    decompress(super)
  end
end