Function _activity_flush_loop

RoverSign/__init__.py:52–62

()

    _shutdown_event = asyncio.Event()

    async def _activity_flush_loop():
        while not _shutdown_event.is_set():
            try:
                await asyncio.wait_for(_shutdown_event.wait(), timeout=_FLUSH_INTERVAL)
                break  # shutdown signaled
            except asyncio.TimeoutError:
                pass
            try:
                await _flush_activity_buffer()
            except Exception as e:
                logger.warning(f"[库洛签到·插件] 活跃度刷写循环异常: {e}")

    _flush_task = asyncio.get_event_loop().create_task(_activity_flush_loop())