async def METHOD_NAME(self):
    self.sub_trans._sub = 'not none'
    with self.assertRaises(TTransportException) as cm:
        await self.sub_trans.subscribe('bar', None)
    self.assertEqual(TTransportException.ALREADY_OPEN, cm.exception.type)