Sha256: 3dec46adccdddb91a2330c7c161503d0638fc421218d939719060e0c77c17027
Contents?: true
Size: 649 Bytes
Versions: 12
Compression:
Stored size: 649 Bytes
Contents
# frozen_string_literal: true
require 'grpc_kit/call'
require 'grpc_kit/calls'
module GrpcKit
module Calls::Client
class ServerStreamer < GrpcKit::Call
include Enumerable
alias outgoing_metadata metadata
# @param data [Object] request message
# @return [void]
def send_msg(data)
@stream.send_msg(data, last: true, metadata: outgoing_metadata)
end
# @return [Object] response object
def recv
@stream.recv_msg
end
# @yieldparam response [Object] each response object of server streaming RPC
def each
loop { yield(recv) }
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems