Searched refs:_rpc (Results 1 – 6 of 6) sorted by relevance
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | _servicer_context.py | 22 self._rpc = rpc
27 return self._rpc.is_active()
30 if self._rpc.is_active():
39 self._rpc.application_cancel()
42 return self._rpc.add_callback(callback)
45 return self._rpc.invocation_metadata()
60 initial_metadata_sent = self._rpc.send_initial_metadata(
67 self._rpc.set_trailing_metadata(
74 self._rpc.set_code(code)
77 self._rpc.set_details(details)
|
| D | _service.py | 21 self._rpc = rpc
30 self._rpc.add_rpc_error(rpc_error)
|
| D | _server.py | 20 from grpc_testing._server import _rpc
73 rpc = _rpc.Rpc(handler, invocation_metadata)
|
| /external/pigweed/pw_rpc/py/pw_rpc/ |
| D | callback_client.py | 98 self._rpc = PendingRpc(channel, method.service, method)
103 return self._rpc.channel
107 return self._rpc.method
111 return self._rpc.service
122 self._rpcs.send_request(self._rpc,
127 return _AsyncCall(self._rpcs, self._rpc)
180 self._rpc = rpc
184 return self._rpcs.send_cancel(self._rpc)
212 …self._method_client._rpcs.send_cancel(self._method_client._rpc) # pylint: disable=protected-access
240 … raise RpcTimeout(self._method_client._rpc, timeout_s) # pylint: disable=protected-access
[all …]
|
| /external/pigweed/pw_rpc/py/tests/ |
| D | callback_client_test.py | 56 def _rpc(method_stub): function
214 mock.call(_rpc(self._service.SomeUnary),
216 mock.call(_rpc(self._service.SomeUnary), Status.ABORTED)
318 rpc = _rpc(self._service.SomeServerStreaming)
338 _rpc(stub), stub.method.response_type(payload='!!!'))
354 mock.call(_rpc(stub), stub.method.response_type(payload='!!!')),
355 mock.call(_rpc(stub), Status.OK),
|
| /external/pigweed/pw_rpc/ |
| D | README.md | 1 # pw\_rpc: Remote procedure calls
|