async def subscribe(self, sub_state, topics):
    'Subscribe to topics.'
    return (await self._subscribe(sub_state, topics))
Subscribe to topics.
async def subscribe(self, sub_state, topics):
    
    return (await self._subscribe(sub_state, topics))