numerous.sdk.connect.request_response_stream module

class numerous.sdk.connect.request_response_stream.RequestResponseStream(stream_endpoint, check_interval_secs=0.1)

Bases: Generic[RequestType, ResponseType]

A helper class for wrapping Stream-Stream gRPCs.

close()

Close the RequestResponseStream blocking until any outstanding request has been delivered.

Return type:

None

send(request)

Sends a request after waiting for the previous request to have been sent, if there is one.

Parameters:

request (TypeVar(RequestType)) – The request to send.

Return type:

TypeVar(ResponseType)

Returns:

The response.