Public Member Functions | |
def | intercept_unary_stream (self, continuation, client_call_details, request) |
Affords intercepting unary-stream invocations.
Definition at line 460 of file src/python/grpcio/grpc/__init__.py.
def grpc.UnaryStreamClientInterceptor.intercept_unary_stream | ( | self, | |
continuation, | |||
client_call_details, | |||
request | |||
) |
Intercepts a unary-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)` 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: The request value 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 464 of file src/python/grpcio/grpc/__init__.py.