Inheritance diagram for grpc.StreamUnaryClientInterceptor:
Public Member Functions | |
| def | intercept_stream_unary (self, continuation, client_call_details, request_iterator) |
Detailed Description
Affords intercepting stream-unary invocations.
Definition at line 494 of file src/python/grpcio/grpc/__init__.py.
Member Function Documentation
◆ intercept_stream_unary()
| def grpc.StreamUnaryClientInterceptor.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 in tests.unit._interceptor_test._LoggingInterceptor, tests.unit._interceptor_test._GenericClientInterceptor, default_value_client_interceptor.DefaultValueClientInterceptor, and generic_client_interceptor._GenericClientInterceptor.
Definition at line 498 of file src/python/grpcio/grpc/__init__.py.
The documentation for this class was generated from the following file: