Sha256: 101be1e6e0e37d8199ab16baa0a87b41b7c005f9c459a40114316135bbfe2578
Contents?: true
Size: 980 Bytes
Versions: 1
Compression:
Stored size: 980 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, @protobuf, 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(@protobuf, last: true, limit_size: @config.max_receive_message_size) end end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
grpc_kit-0.2.0 | lib/grpc_kit/calls/server_request_response.rb |