Contents

module Zstd
  # @todo Exprimental
  class StreamWriter
    def initialize(io, level: nil)
      @io = io
      @stream = Zstd::StreamingCompress.new(level)
    end

    def write(*data)
      @stream.write(*data)
      @io.write(@stream.flush)
    end

    def finish
      @io.write(@stream.finish)
    end

    def close
      @io.write(@stream.finish)
      @io.close
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
zstd-ruby-1.5.6.5	lib/zstd-ruby/stream_writer.rb
zstd-ruby-1.5.6.4	lib/zstd-ruby/stream_writer.rb
zstd-ruby-1.5.6.3	lib/zstd-ruby/stream_writer.rb
zstd-ruby-1.5.6.2	lib/zstd-ruby/stream_writer.rb