Sha256: c1fb90335cee3ac99e850d1182eae576d281b271e3a3b37788d71f1814a6e9b4
Contents?: true
Size: 774 Bytes
Versions: 6
Compression:
Stored size: 774 Bytes
Contents
# frozen_string_literal: true
require 'grpc_kit/calls'
module GrpcKit
module Calls::Client
class ClientStreamer < 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
# @return [Array<Object>] response objects
def close_and_recv
@stream.close_and_recv
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems