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