Sha256: a6e697b6afea6a7b9b575e15a3e381bc6b82eae740b14e8536b7f5ffb2abfc47
Contents?: true
Size: 659 Bytes
Versions: 6
Compression:
Stored size: 659 Bytes
Contents
# frozen_string_literal: true
require 'grpc_kit/calls'
module GrpcKit
module Calls::Client
class RequestResponse < GrpcKit::Calls::Call
alias outgoing_metadata metadata
# @param data [Object] request message
# @param last [Boolean]
# @return [void]
def send_msg(data, last: false)
raise 'No method error' if @restrict
@stream.send_msg(data, last: last, metadata: outgoing_metadata)
end
# @param last [Boolean]
# @return [Object] response object
def recv(last: false)
raise 'No method error' if @restrict
@stream.recv_msg(last: last)
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems