Inheritance diagram for grpc.StreamStreamClientInterceptor:
Public Member Functions | |
| def | intercept_stream_stream (self, continuation, client_call_details, request_iterator) |
Detailed Description
Affords intercepting stream-stream invocations.
Definition at line 528 of file src/python/grpcio/grpc/__init__.py.
Member Function Documentation
◆ intercept_stream_stream()
| def grpc.StreamStreamClientInterceptor.intercept_stream_stream | ( | self, | |
| continuation, | |||
| client_call_details, | |||
| request_iterator | |||
| ) |
Intercepts a stream-stream invocation.
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_iterator = continuation(client_call_details, request_iterator)`
to continue with the RPC. `continuation` returns an object that is
both a Call for the RPC and an iterator for response values.
Drawing response values from the returned Call-iterator may
raise RpcError indicating termination of the RPC with non-OK
status.
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 an iterator of
response values. Drawing response values from the returned
Call-iterator may raise RpcError indicating termination of
the RPC with non-OK status. This object *should* also fulfill the
Future interface, though it may not.
Reimplemented in tests.unit._interceptor_test._LoggingInterceptor, tests.unit._interceptor_test._GenericClientInterceptor, and generic_client_interceptor._GenericClientInterceptor.
Definition at line 532 of file src/python/grpcio/grpc/__init__.py.
The documentation for this class was generated from the following file: