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

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

#append(data, **kwargs) ⇒ Object 



187
188
189
190
191
192
193
194
195
196
197
198
199
 
# File 'lib/fluent/plugin/buffer/chunk.rb', line 187

def append(data, **kwargs)
  if kwargs[:compress] == :gzip
    io = StringIO.new
    Zlib::GzipWriter.wrap(io) do |gz|
      data.each do |d|
        gz.write d
      end
    end
    concat(io.string, data.size)
  else
    super
  end
end