Method: SynchronizedCancellationService#an_rpc

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

#an_rpc(req, _call) ⇒ Object 


105
106
107
108
109
110
 
# File 'src/ruby/spec/generic/rpc_server_spec.rb', line 105

def an_rpc(req, _call)
  GRPC.logger.info('starting a synchronusly cancelled rpc')
  @notify_request_received.call(req)
  @wait_until_rpc_cancelled.call
  req  # send back the req as the response
end