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

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

#write_to(io, **kwargs) ⇒ Object 



227
228
229
230
231
232
233
234
235
 
# File 'lib/fluent/plugin/buffer/chunk.rb', line 227

def write_to(io, **kwargs)
  open(compressed: :gzip) do |chunk_io|
    if kwargs[:compressed] == :gzip
      IO.copy_stream(chunk_io, io)
    else
      decompress(input_io: chunk_io, output_io: io)
    end
  end
end