Method: CheckCallAfterFinishedService#a_client_streaming_rpc

Defined in:
src/ruby/spec/generic/rpc_server_spec.rb

#a_client_streaming_rpc(call) ⇒ Object 



132
133
134
135
136
137
138
 
# File 'src/ruby/spec/generic/rpc_server_spec.rb', line 132

def a_client_streaming_rpc(call)
  fail 'shouldnt reuse service' unless @server_side_call.nil?
  @server_side_call = call
  # iterate through requests so call can complete
  call.each_remote_read.each { |r| GRPC.logger.info(r) }
  EchoMsg.new
end