def test_forward_request_conn_closed(self):
    self._sync_rpc_client.forward_request(SyncRPCRequest(reqId=12345, connClosed=True))
    self.assertEqual(self._sync_rpc_client._conn_closed_table[12345], True)
def test_forward_request_conn_closed(self):
    self._sync_rpc_client.forward_request(SyncRPCRequest(reqId=12345, connClosed=True))
    self.assertEqual(self._sync_rpc_client._conn_closed_table[12345], True)