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