◆ __init__()
def default_value_client_interceptor.DefaultValueClientInterceptor.__init__ |
( |
|
self, |
|
|
|
value |
|
) |
| |
◆ _intercept_call()
def default_value_client_interceptor.DefaultValueClientInterceptor._intercept_call |
( |
|
self, |
|
|
|
continuation, |
|
|
|
client_call_details, |
|
|
|
request_or_iterator |
|
) |
| |
|
private |
◆ intercept_stream_unary()
def default_value_client_interceptor.DefaultValueClientInterceptor.intercept_stream_unary |
( |
|
self, |
|
|
|
continuation, |
|
|
|
client_call_details, |
|
|
|
request_iterator |
|
) |
| |
Intercepts a stream-unary invocation asynchronously.
Args:
continuation: A function that proceeds with the invocation by
executing the next interceptor in 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
`response_future = continuation(client_call_details, request_iterator)`
to continue with the RPC. `continuation` returns an object that is
both a Call for the RPC and a Future. In the event of RPC completion,
the return Call-Future's result value will be the response message
of the RPC. Should the event terminate with non-OK status, the
returned Call-Future's exception value will be an RpcError.
client_call_details: A ClientCallDetails object describing the
outgoing RPC.
request_iterator: An iterator that yields request values for the RPC.
Returns:
An object that is both a Call for the RPC and a Future.
In the event of RPC completion, the return Call-Future's
result value will be the response message of the RPC.
Should the event terminate with non-OK status, the returned
Call-Future's exception value will be an RpcError.
Reimplemented from grpc.StreamUnaryClientInterceptor.
Definition at line 63 of file default_value_client_interceptor.py.
◆ intercept_unary_unary()
def default_value_client_interceptor.DefaultValueClientInterceptor.intercept_unary_unary |
( |
|
self, |
|
|
|
continuation, |
|
|
|
client_call_details, |
|
|
|
request |
|
) |
| |
Intercepts a unary-unary invocation asynchronously.
Args:
continuation: A function that proceeds with the invocation by
executing the next interceptor in 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
`response_future = continuation(client_call_details, request)`
to continue with the RPC. `continuation` returns an object that is
both a Call for the RPC and a Future. In the event of RPC
completion, the return Call-Future's result value will be
the response message of the RPC. Should the event terminate
with non-OK status, the returned Call-Future's exception value
will be an RpcError.
client_call_details: A ClientCallDetails object describing the
outgoing RPC.
request: The request value for the RPC.
Returns:
An object that is both a Call for the RPC and a Future.
In the event of RPC completion, the return Call-Future's
result value will be the response message of the RPC.
Should the event terminate with non-OK status, the returned
Call-Future's exception value will be an RpcError.
Reimplemented from grpc.UnaryUnaryClientInterceptor.
Definition at line 60 of file default_value_client_interceptor.py.
◆ _default
default_value_client_interceptor.DefaultValueClientInterceptor._default |
|
private |
The documentation for this class was generated from the following file: