Public Member Functions | |
Union[UnaryUnaryCall, ResponseType] | intercept_unary_unary (self, Callable[[ClientCallDetails, RequestType], UnaryUnaryCall] continuation, ClientCallDetails client_call_details, RequestType request) |
Affords intercepting unary-unary invocations.
Definition at line 106 of file aio/_interceptor.py.
Union[UnaryUnaryCall, ResponseType] grpc.aio._interceptor.UnaryUnaryClientInterceptor.intercept_unary_unary | ( | self, | |
Callable[[ClientCallDetails, RequestType], UnaryUnaryCall] | continuation, | ||
ClientCallDetails | client_call_details, | ||
RequestType | request | ||
) |
Affords intercepting unary-unary invocations.
Intercepts a unary-unary invocation asynchronously. Args: continuation: A coroutine that proceeds with the invocation by executing the next interceptor in the chain or invoking the actual RPC on the underlying Channel. It is the interceptor's responsibility to call it if it decides to move the RPC forward. The interceptor can use `call = await continuation(client_call_details, request)` to continue with the RPC. `continuation` returns the call to the RPC. client_call_details: A ClientCallDetails object describing the outgoing RPC. request: The request value for the RPC. Returns: An object with the RPC response. Raises: AioRpcError: Indicating that the RPC terminated with non-OK status. asyncio.CancelledError: Indicating that the RPC was canceled.
Definition at line 110 of file aio/_interceptor.py.