Searched refs:PendingRpc (Results 1 – 3 of 3) sorted by relevance
| /external/pigweed/pw_rpc/py/pw_rpc/ |
| D | callback_client.py | 55 from pw_rpc.client import PendingRpc, PendingRpcs
68 ResponseCallback = Callable[[PendingRpc, Any], Any]
69 CompletionCallback = Callable[[PendingRpc, Status], Any]
70 ErrorCallback = Callable[[PendingRpc, Status], Any]
79 def _default_response(rpc: PendingRpc, response: Any) -> None: argument
83 def _default_completion(rpc: PendingRpc, status: Status) -> None: argument
87 def _default_error(rpc: PendingRpc, status: Status) -> None: argument
98 self._rpc = PendingRpc(channel, method.service, method)
155 def __init__(self, rpc: PendingRpc, timeout: Optional[float]): argument
163 def __init__(self, rpc: PendingRpc, status: Status): argument
[all …]
|
| D | client.py | 36 class PendingRpc(NamedTuple): class
55 self._pending: Dict[PendingRpc, _PendingRpcMetadata] = {}
58 rpc: PendingRpc, argument
70 rpc: PendingRpc, argument
82 rpc: PendingRpc, argument
101 def cancel(self, rpc: PendingRpc) -> Optional[bytes]: argument
118 def send_cancel(self, rpc: PendingRpc) -> bool: argument
130 def get_pending(self, rpc: PendingRpc, status: Optional[Status]): argument
159 rpc: PendingRpc, argument
176 rpc: PendingRpc, argument
[all …]
|
| /external/pigweed/pw_rpc/py/tests/ |
| D | callback_client_test.py | 57 return client.PendingRpc(method_stub.channel, method_stub.method.service,
|