def METHOD_NAME(self):
    with manage_run(self), manage_asyncgens(self):
        while True:
            self._run_once()
            if self._stopping:
                break
    self._stopping = False