# frozen_string_literal: true module HTTPX module Plugins module Compression module Deflate def self.load_dependencies(_klass) require "stringio" require "zlib" end def self.configure(klass) klass.plugin(:"compression/gzip") klass.default_options.encodings.register "deflate", self end module Deflater module_function def deflate(raw, buffer = "".b, chunk_size: 16_384) deflater = Zlib::Deflate.new while (chunk = raw.read(chunk_size)) compressed = deflater.deflate(chunk) buffer << compressed yield compressed if block_given? end last = deflater.finish buffer << last yield last if block_given? buffer ensure deflater.close if deflater end end module_function def deflater Deflater end def inflater(bytesize) GZIP::Inflater.new(bytesize) end end end register_plugin :"compression/deflate", Compression::Deflate end end