async def METHOD_NAME(self):
    self.mock_nats_client.is_connected = True
    self.transport._is_open = True
    with self.assertRaises(TTransportException) as cm:
        await self.transport.open()
    self.assertEqual(TTransportExceptionType.ALREADY_OPEN, cm.exception.type)