class Schlepp::Sink::TableObject::Compressor::Stream
Public Class Methods
new()
click to toggle source
# File lib/schlepp/sink/filter/compressor/stream.rb, line 8 def initialize @buffer = StringIO.new("", "rb+") @compressor = Zlib::GzipWriter.new(@buffer) @dead = false end
Public Instance Methods
finalize()
click to toggle source
# File lib/schlepp/sink/filter/compressor/stream.rb, line 28 def finalize if !@dead @compressor.close @dead = true end end
length()
click to toggle source
# File lib/schlepp/sink/filter/compressor/stream.rb, line 21 def length if @dead raise "Stream has been dumped. No more writing permitted." end @compressor.pos end
to_s()
click to toggle source
# File lib/schlepp/sink/filter/compressor/stream.rb, line 35 def to_s finalize @buffer.string end
write(data)
click to toggle source
# File lib/schlepp/sink/filter/compressor/stream.rb, line 14 def write(data) if @dead raise "Stream has been dumped. No more writing permitted." end @compressor << data end