| D | _service.py | 21 def __init__(self, rpc, handler): argument 22 self._rpc = rpc 46 def _unary_response(argument, implementation, rpc, servicer_context): argument 50 rpc.application_exception_abort(exception) 52 rpc.unary_response_complete(response) 55 def _stream_response(argument, implementation, rpc, servicer_context): argument 59 rpc.application_exception_abort(exception) 65 rpc.stream_response_complete() 68 rpc.application_exception_abort(exception) 71 rpc.stream_response(response) [all …]
|