class Protocol::HTTP::Body::Inflate

A body which decompresses the contents using the DEFLATE or GZIP algorithm.

def self.for(body, window_size = GZIP)

@parameter window_size [Integer] the window size to use for decompression.
@parameter body [Readable] the body to wrap.

Create a new body which decompresses the given body using the GZIP algorithm by default. 
def self.for(body, window_size = GZIP)
	self.new(body, Zlib::Inflate.new(window_size))
end

def read

@returns [String | Nil] the inflated data, or nil if the stream is finished.

Read from the underlying stream and inflate it. 
def read
	if stream = @stream
		# Read from the underlying stream and inflate it:
		while chunk = super
			@input_length += chunk.bytesize
			
			# It's possible this triggers the stream to finish.
			chunk = stream.inflate(chunk)
			
			break unless chunk&.empty?
		end
	
		if chunk
			@output_length += chunk.bytesize
		elsif !stream.closed?
			chunk = stream.finish
			@output_length += chunk.bytesize
		end
		
		# If the stream is finished, we need to close it and potentially return nil:
		if stream.finished?
			@stream = nil
			stream.close
			
			while super
				# There is data left in the stream, so we need to keep reading until it's all consumed.
			end
			
			if chunk.empty?
				return nil
			end
		end
		
		return chunk
	end
end