class GrpcKit::Calls::Client::ServerStreamer
Public Instance Methods
each() { |recv| ... }
click to toggle source
@yieldparam response [Object] each response object of server streaming RPC
# File lib/grpc_kit/calls/client_server_streamer.rb, line 26 def each loop { yield(recv) } end
recv()
click to toggle source
This method is not thread safe, never call from multiple threads at once. @return [Object] response object
# File lib/grpc_kit/calls/client_server_streamer.rb, line 21 def recv @stream.recv_msg end
send_msg(data)
click to toggle source
@param data [Object] request message @return [void]
# File lib/grpc_kit/calls/client_server_streamer.rb, line 15 def send_msg(data) @stream.send_msg(data, last: true, metadata: outgoing_metadata) end