Sha256: 1bb238c69ae071f1b9ef94239dbc40e2f332fd5c45dd17809052137250d97179
Contents?: true
Size: 479 Bytes
Versions: 15
Compression:
Stored size: 479 Bytes
Contents
# frozen_string_literal: true
require 'grpc_kit/call'
require 'grpc_kit/calls'
module GrpcKit
module Calls::Client
class ClientStreamer < GrpcKit::Call
alias outgoing_metadata metadata
# @param data [Object] request message
# @return [void]
def send_msg(data)
@stream.send_msg(data, metadata: outgoing_metadata)
end
# @return [Object] response object
def recv
@stream.close_and_recv
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems