Searched defs:PendingRpc (Results 1 – 9 of 9) sorted by relevance
| /external/pigweed/pw_rpc/py/pw_rpc/ |
| D | client.py | 72 self, rpc: PendingRpc, request: Message | None, context: object
80 self, rpc: PendingRpc, request: Message | None, context: object
91 def open(self, rpc: PendingRpc, context: object) -> None:
111 def send_client_stream(self, rpc: PendingRpc, message: Message) -> None:
117 def send_client_stream_end(self, rpc: PendingRpc) -> None:
125 def cancel(self, rpc: PendingRpc) -> bytes:
139 def send_cancel(self, rpc: PendingRpc) -> bool:
152 self, rpc: PendingRpc, completed: bool
189 self, rpc: PendingRpc, completed: bool
219 rpc: PendingRpc,
[all …]
|
| D | descriptors.py | 472 class PendingRpc: class
512 def matches_channel_service_method(self, other: PendingRpc) -> bool:
|
| /external/pigweed/pw_rpc/py/pw_rpc/callback_client/ |
| D | errors.py | 23 def __init__(self, rpc: PendingRpc, timeout: float | None):
32 def __init__(self, rpc: PendingRpc, status: Status):
|
| D | impl.py | 559 rpc: PendingRpc,
568 rpc: PendingRpc,
576 rpc: PendingRpc,
|
| D | call.py | 102 rpc: PendingRpc,
|
| /external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| D | Endpoint.java | 64 BiFunction<Endpoint, PendingRpc, CallT> createCall, in invokeRpc() argument
88 int channelId, Method method, BiFunction<Endpoint, PendingRpc, CallT> createCall) { in openRpc() argument
96 int channelId, Method method, BiFunction<Endpoint, PendingRpc, CallT> createCall) { in createCall() argument
|
| D | PendingRpc.java | 26 abstract class PendingRpc { class
|
| D | MethodClient.java | 194 invokeFuture(BiFunction<Endpoint, PendingRpc, CallT> createCall, @Nullable MessageLite request) { in invokeFuture() argument
|
| /external/pigweed/pw_rpc/py/tests/ |
| D | client_test.py | 395 rpc: client.PendingRpc,
|