Sha256: 54be50f01ea7c67e0d09a325a0513baca629eb05749de88739c9cfff09b68791
Contents?: true
Size: 975 Bytes
Versions: 3
Compression:
Stored size: 975 Bytes
Contents
# frozen_string_literal: true require 'grpc_kit/call' require 'grpc_kit/calls' module GrpcKit module Calls::Server class RequestResponse < GrpcKit::Call attr_reader :outgoing_initial_metadata, :outgoing_trailing_metadata alias incoming_metadata metadata def initialize(**) super @outgoing_initial_metadata = {} @outgoing_trailing_metadata = {} end # @param data [Object] request message # @param last [Boolean] # @return [void] 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 # @return [Object] response object def recv @stream.recv_msg(@codec, last: true, limit_size: @config.max_receive_message_size) end end end end
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
grpc_kit-0.5.1 | lib/grpc_kit/calls/server_request_response.rb |
grpc_kit-0.5.0 | lib/grpc_kit/calls/server_request_response.rb |
grpc_kit-0.4.0 | lib/grpc_kit/calls/server_request_response.rb |