async def _close(self):
<EOL>try:<EOL><INDENT>if self._hb_inbox_sid is not None:<EOL><INDENT>await self._nc.unsubscribe(self._hb_inbox_sid)<EOL>self._hb_inbox = None<EOL>self._hb_inbox_sid = None<EOL><DEDENT>if self._ack_subject_sid is not None:<EOL><INDENT>await self._nc.unsubscribe(self._ack_subject_sid)<EOL>self._ack_subject = None<EOL>self._ack_subject_sid = None<EOL><DEDENT><DEDENT>except:<EOL><INDENT>pass<EOL><DEDENT>for _, sub in self._sub_map.items():<EOL><INDENT>if sub._msgs_task is not None:<EOL><INDENT>sub._msgs_task.cancel()<EOL><DEDENT>try:<EOL><INDENT>await self._nc.unsubscribe(sub.sid)<EOL><DEDENT>except:<EOL><INDENT>continue<EOL><DEDENT><DEDENT>self._sub_map = {}<EOL>
Removes any present internal state from the client.