Public Member Functions | |
| def | cancel (self) |
| def | initial_metadata (self) |
| def | requests_closed (self) |
| def | send_request (self, request) |
| def | take_response (self) |
| def | termination (self) |
Detailed Description
Fixture for a stream-stream RPC serviced by a system under test. Enables users to "play client" for the RPC.
Definition at line 430 of file src/python/grpcio_testing/grpc_testing/__init__.py.
Member Function Documentation
◆ cancel()
| def grpc_testing.StreamStreamServerRpc.cancel | ( | self | ) |
Cancels the RPC.
Reimplemented in grpc_testing._server._server_rpc.StreamStreamServerRpc.
Definition at line 478 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ initial_metadata()
| def grpc_testing.StreamStreamServerRpc.initial_metadata | ( | self | ) |
Accesses the initial metadata emitted by the system under test. This method blocks until the system under test has added initial metadata to the RPC (or has provided one or more response messages or has terminated the RPC, either of which will cause gRPC Python to synthesize initial metadata for the RPC). Returns: The initial metadata for the RPC.
Reimplemented in grpc_testing._server._server_rpc.StreamStreamServerRpc.
Definition at line 437 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ requests_closed()
| def grpc_testing.StreamStreamServerRpc.requests_closed | ( | self | ) |
Indicates the end of the RPC's request stream.
Reimplemented in grpc_testing._server._server_rpc.StreamStreamServerRpc.
Definition at line 461 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ send_request()
| def grpc_testing.StreamStreamServerRpc.send_request | ( | self, | |
| request | |||
| ) |
Sends a request to the system under test.
Args:
request: A request message for the RPC to be "sent" to the system
under test.
Reimplemented in grpc_testing._server._server_rpc.StreamStreamServerRpc.
Definition at line 451 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ take_response()
| def grpc_testing.StreamStreamServerRpc.take_response | ( | self | ) |
Draws one of the responses added to the RPC by the system under test. Successive calls to this method return responses in the same order in which the system under test added them to the RPC. Returns: A response message added to the RPC by the system under test.
Reimplemented in grpc_testing._server._server_rpc.StreamStreamServerRpc.
Definition at line 466 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ termination()
| def grpc_testing.StreamStreamServerRpc.termination | ( | self | ) |
Blocks until the system under test has terminated the RPC.
Returns:
A (trailing_metadata, code, details) sequence with the RPC's trailing
metadata, code, and details.
Reimplemented in grpc_testing._server._server_rpc.StreamStreamServerRpc.
Definition at line 483 of file src/python/grpcio_testing/grpc_testing/__init__.py.
The documentation for this class was generated from the following file: