async def METHOD_NAME(self) -> None:
    while True:
        time.sleep(0.2)
        try:
            await self._on_events()
        except Exception as e:
            logger.error("Unexpected error when processing events", exc_info=e)