docs: def _reset(self):
          """Initialization that must happen before the broker is (re)started."""
          self._subscriber_thread = None
          self._must_stop = threading.Event()
          self._number_periodic_tasks = 0