123456789_123456789_123456789_123456789_123456789_

Class: Net::HTTPResponse::Inflater

Do not use. This class is for internal use only.
Relationships & Source Files
Inherits: Object
Defined in: lib/net/http/response.rb

Overview

Inflater is a wrapper around Net::BufferedIO that transparently inflates zlib and gzip streams.

Class Method Summary

Instance Method Summary

Constructor Details

.new(socket) ⇒ Inflater

Creates a new Inflater wrapping socket

[ GitHub ] 

  


# File 'lib/net/http/response.rb', line 355



def initialize socket
  @socket = socket
  # zlib with automatic gzip detection
  @inflate = Zlib::Inflate.new(32 + Zlib::MAX_WBITS)
end


  







Instance Method Details



  

    #finish  
  



  

    

Finishes the inflate stream.


  



  [ GitHub ]


  

  


# File 'lib/net/http/response.rb', line 364



def finish
  return if @inflate.total_in == 0
  @inflate.finish
end


  








  

    #inflate_adapter(dest)  
  



  

    

Returns a Net::ReadAdapter that inflates each read chunk into dest.



This allows a large response body to be inflated without storing the entire body in memory.


  



  [ GitHub ]


  

  


# File 'lib/net/http/response.rb', line 375



def inflate_adapter(dest)
  if dest.respond_to?(:set_encoding)
    dest.set_encoding(Encoding::ASCII_8BIT)
  elsif dest.respond_to?(:force_encoding)
    dest.force_encoding(Encoding::ASCII_8BIT)
  end
  block = proc do |compressed_chunk|
    @inflate.inflate(compressed_chunk) do |chunk|
      dest << chunk
    end
  end

  Net::ReadAdapter.new(block)
end


  








  

    #read(clen, dest, ignore_eof = false)  
  



  

    

Reads clen bytes from the socket, inflates them, then writes them to dest.  ignore_eof is passed down to Net::BufferedIO#read



Unlike Net::BufferedIO#read, this method returns more than clen bytes. At this time there is no way for a user of ::Net::HTTPResponse to read a specific number of bytes from the ::Net::HTTP response body, so this internal API does not return the same number of bytes as were requested.



See bugs.ruby-lang.org/issues/6492 for further discussion.


  



  [ GitHub ]


  

  


# File 'lib/net/http/response.rb', line 401



def read clen, dest, ignore_eof = false
  temp_dest = inflate_adapter(dest)

  @socket.read clen, temp_dest, ignore_eof
end


  








  

    #read_all(dest)  
  



  

    

Reads the rest of the socket, inflates it, then writes it to dest.


  



  [ GitHub ]


  

  


# File 'lib/net/http/response.rb', line 410



def read_all dest
  temp_dest = inflate_adapter(dest)

  @socket.read_all temp_dest
end