Public Member Functions | |
None | __init__ (self, RequestType request, Optional[float] deadline, Metadata metadata, Optional[grpc.CallCredentials] credentials, Optional[bool] wait_for_ready, cygrpc.AioChannel channel, bytes method, SerializingFunction request_serializer, DeserializingFunction response_deserializer, asyncio.AbstractEventLoop loop) |
None | wait_for_connection (self) |
![]() | |
ResponseType | __await__ (self) |
bool | cancel (self) |
![]() | |
None | __del__ (self) |
None | __init__ (self, cygrpc._AioCall cython_call, Metadata metadata, SerializingFunction request_serializer, DeserializingFunction response_deserializer, asyncio.AbstractEventLoop loop) |
str | __repr__ (self) |
str | __str__ (self) |
None | add_done_callback (self, DoneCallbackType callback) |
bool | cancelled (self) |
grpc.StatusCode | code (self) |
str | debug_error_string (self) |
str | details (self) |
bool | done (self) |
Metadata | initial_metadata (self) |
Optional[float] | time_remaining (self) |
Metadata | trailing_metadata (self) |
![]() | |
Awaitable[ResponseType] | __await__ (self) |
![]() | |
grpc.StatusCode | code (self) |
str | details (self) |
Metadata | initial_metadata (self) |
Metadata | trailing_metadata (self) |
![]() | |
None | add_done_callback (self, DoneCallbackType callback) |
bool | cancel (self) |
bool | cancelled (self) |
bool | done (self) |
Optional[float] | time_remaining (self) |
Private Member Functions | |
ResponseType | _invoke (self) |
Private Attributes | |
_invocation_task | |
_request | |
Object for managing unary-unary RPC calls. Returned when an instance of `UnaryUnaryMultiCallable` object is called.
None grpc.aio._call.UnaryUnaryCall.__init__ | ( | self, | |
RequestType | request, | ||
Optional[float] | deadline, | ||
Metadata | metadata, | ||
Optional[grpc.CallCredentials] | credentials, | ||
Optional[bool] | wait_for_ready, | ||
cygrpc.AioChannel | channel, | ||
bytes | method, | ||
SerializingFunction | request_serializer, | ||
DeserializingFunction | response_deserializer, | ||
asyncio.AbstractEventLoop | loop | ||
) |
|
private |
None grpc.aio._call.UnaryUnaryCall.wait_for_connection | ( | self | ) |
Waits until connected to peer and raises aio.AioRpcError if failed. This is an EXPERIMENTAL method. This method ensures the RPC has been successfully connected. Otherwise, an AioRpcError will be raised to explain the reason of the connection failure. This method is recommended for building retry mechanisms.
Reimplemented from grpc.aio._base_call.Call.