async def rt_connect(self, loop):
if self.sub_manager is not None:<EOL><INDENT>return<EOL><DEDENT>self.sub_manager = SubscriptionManager(<EOL>loop, "<STR_LIT>".format(self._access_token), SUB_ENDPOINT<EOL>)<EOL>self.sub_manager.start()<EOL>
Start subscription manager for real time data.