class GrpcKit::Calls::Server::RequestResponse

Attributes

outgoing_initial_metadata[R]
outgoing_trailing_metadata[R]

Public Class Methods

new(**) click to toggle source
Calls superclass method GrpcKit::Call::new
# File lib/grpc_kit/calls/server_request_response.rb, line 12
def initialize(**)
  super

  @outgoing_initial_metadata = {}
  @outgoing_trailing_metadata = {}
end

Public Instance Methods

recv() click to toggle source

@return [Object] response object

# File lib/grpc_kit/calls/server_request_response.rb, line 34
def recv
  @stream.recv_msg(@codec, last: true, limit_size: @config.max_receive_message_size)
end
send_msg(data) click to toggle source

@param data [Object] request message @param last [Boolean] @return [void]

# File lib/grpc_kit/calls/server_request_response.rb, line 22
def send_msg(data)
  @stream.send_msg(
    data,
    @codec,
    last: true,
    initial_metadata: @outgoing_initial_metadata,
    trailing_metadata: @outgoing_trailing_metadata,
    limit_size: @config.max_send_message_size,
  )
end