def METHOD_NAME(
        self,
        req: SessionRequest,
) -> SessionResponse:
    self.requests.put(req)
    if self.session is None:
        self.session = self.stub.Session(self._next_request())
    resp = next(self.session)
    if resp.HasField('error_response'):
        raise SessionReceiveError(resp.error_response.message)
    return resp