Contents

module Snappy
  class Writer
    if RUBY_VERSION[0..2] == '1.8'
      MAGIC = "\x82SNAPPY\x0"
    else
      MAGIC = "\x82SNAPPY\x0".force_encoding Encoding::ASCII_8BIT
    end
    DEFAULT_VERSION = 1
    MINIMUM_COMPATIBLE_VERSION = 1
    DEFAULT_BLOCK_SIZE = 32 * 1024

    attr_reader :io, :block_size

    def initialize(io, block_size = DEFAULT_BLOCK_SIZE)
      @block_size = block_size
      @buffer = ""
      @io = io
      @io.set_encoding Encoding::ASCII_8BIT unless RUBY_VERSION =~ /^1\.8/
      write_header!
      if block_given?
        yield self
        dump!
      end
    end

    def <<(msg)
      @buffer << msg.to_s
      dump! if @buffer.size > @block_size
    end

    alias_method :write, :<<

    def dump!
      compressed = Snappy.deflate(@buffer)
      @io << [compressed.size, compressed].pack("Na#{compressed.size}")
      @io.flush
      @buffer = ""
    end

    alias_method :flush, :dump!

    def close
      @io.close
    end

    private

    def write_header!
      @io << [MAGIC, DEFAULT_VERSION, MINIMUM_COMPATIBLE_VERSION].pack("a8NN")
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
snappy-0.0.15-java	lib/snappy/writer.rb
snappy-0.0.15	lib/snappy/writer.rb
snappy-0.0.14-java	lib/snappy/writer.rb
snappy-0.0.14	lib/snappy/writer.rb
snappy-0.0.13	lib/snappy/writer.rb