Class: HTTPX::Transcoder::GRPCEncoding::Inflater

Inherits:
Object
  • Object
show all
Defined in:
lib/httpx/plugins/grpc/grpc_encoding.rb,
sig/plugins/grpc/grpc_encoding.rbs

Instance Method Summary collapse

Constructor Details

#initialize(response) ⇒ Inflater

Returns a new instance of Inflater.

Parameters:



40
41
42
43
 
# File 'lib/httpx/plugins/grpc/grpc_encoding.rb', line 40

def initialize(response)
  @response = response
  @grpc_encodings = nil
end

Instance Method Details

#call(message, &blk) ⇒ void

This method returns an undefined value.

Parameters:

  • message (String) 


45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/httpx/plugins/grpc/grpc_encoding.rb', line 45

def call(message, &blk)
  data = "".b

  until message.empty?
    compressed, size = message.unpack("CL>")

    encoded_data = message.byteslice(5..(size + 5 - 1))

    if compressed == 1
      grpc_encodings.reverse_each do |encoding|
        decoder = @response.body.class.initialize_inflater_by_encoding(encoding, @response, bytesize: encoded_data.bytesize)
        encoded_data = decoder.call(encoded_data)

        blk.call(encoded_data) if blk

        data << encoded_data
      end
    else
      blk.call(encoded_data) if blk

      data << encoded_data
    end

    message = message.byteslice((size + 5)..-1)
  end

  data
end

#grpc_encodings ⇒ Array[String]

Returns:

  • (Array[String]) 


76
77
78
 
# File 'lib/httpx/plugins/grpc/grpc_encoding.rb', line 76

def grpc_encodings
  @grpc_encodings ||= @response.headers.get("grpc-encoding")
end