Public Member Functions | |
| def | cancelled (self) |
| def | requests_closed (self) |
| def | send_initial_metadata (self, initial_metadata) |
| def | send_response (self, response) |
| def | take_request (self) |
| def | terminate (self, trailing_metadata, code, details) |
Detailed Description
Fixture for a stream-stream RPC invoked by a system under test. Enables users to "play server" for the RPC.
Definition at line 153 of file src/python/grpcio_testing/grpc_testing/__init__.py.
Member Function Documentation
◆ cancelled()
| def grpc_testing.StreamStreamChannelRpc.cancelled | ( | self | ) |
Blocks until the system under test has cancelled the RPC.
Reimplemented in grpc_testing._channel._channel_rpc._StreamStream.
Definition at line 199 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ requests_closed()
| def grpc_testing.StreamStreamChannelRpc.requests_closed | ( | self | ) |
Blocks until the system under test has closed the request stream.
Reimplemented in grpc_testing._channel._channel_rpc._StreamStream.
Definition at line 194 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ send_initial_metadata()
| def grpc_testing.StreamStreamChannelRpc.send_initial_metadata | ( | self, | |
| initial_metadata | |||
| ) |
Sends the RPC's initial metadata to the system under test.
Args:
initial_metadata: The RPC's initial metadata to be "sent" to the
system under test.
Reimplemented in grpc_testing._channel._channel_rpc._StreamStream.
Definition at line 160 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ send_response()
| def grpc_testing.StreamStreamChannelRpc.send_response | ( | self, | |
| response | |||
| ) |
Sends a response to the system under test. Args: response: A response messages to be "sent" to the system under test.
Reimplemented in grpc_testing._channel._channel_rpc._StreamStream.
Definition at line 185 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ take_request()
| def grpc_testing.StreamStreamChannelRpc.take_request | ( | self | ) |
Draws one of the requests added to the RPC by the system under test. This method blocks until the system under test has added to the RPC the request to be returned. Successive calls to this method return requests in the same order in which the system under test added them to the RPC. Returns: A request message added to the RPC by the system under test.
Reimplemented in grpc_testing._channel._channel_rpc._StreamStream.
Definition at line 170 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ terminate()
| def grpc_testing.StreamStreamChannelRpc.terminate | ( | self, | |
| trailing_metadata, | |||
| code, | |||
| details | |||
| ) |
Terminates the RPC. Args: trailing_metadata: The RPC's trailing metadata. code: The RPC's status code. details: The RPC's status details.
Reimplemented in grpc_testing._channel._channel_rpc._StreamStream.
Definition at line 204 of file src/python/grpcio_testing/grpc_testing/__init__.py.
The documentation for this class was generated from the following file: