code: async def setup_watchdog(self, cb, timeout):
          
          self._watchdog_timeout = timeout
          self._watchdog_cb = cb
          self._watchdog_task = self.loop.create_task(self._watchdog(timeout))
docs: Trigger a reconnect after @timeout seconds of inactivity.