Contents

# frozen_string_literal: true

require 'zlib'

module SqlToCsvStream
  class GzipWrapper
    def initialize(source)
      @source = source
    end

    def each(&block)
      @destination = block
      # Zlib::GzipWriter needs to get passed an object that implements the #write method.
      # this is why we implement the #write method further down
      # while assigning the stream we need to write to in an instance variable to be used there.
      @zipper = Zlib::GzipWriter.new(self)
      @source.each do |string|
        @zipper.write(string)
      end
    ensure
      @zipper.close
    end

    # called indirectly by Zlib::GzipWriter
    def write(zipped_string)
      @destination.yield(zipped_string)
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sql_to_csv_stream-0.3.0	lib/sql_to_csv_stream/gzip_wrapper.rb
sql_to_csv_stream-0.2.2	lib/sql_to_csv_stream/gzip_wrapper.rb
sql_to_csv_stream-0.2.1	lib/sql_to_csv_stream/gzip_wrapper.rb
sql_to_csv_stream-0.2.0	lib/sql_to_csv_stream/gzip_wrapper.rb