如何打破没有任何传入消息的(asyncio) websocket fetch循环？

import asyncio

async def fetch_data():
    # 进行websocket连接和数据接收操作
    ...

async def main():
    try:
        await asyncio.wait_for(fetch_data(), timeout=10)
    except asyncio.TimeoutError:
        # 在超时后执行相应的操作
        ...

asyncio.run(main())

import asyncio

async def fetch_data():
    # 进行websocket连接和数据接收操作
    ...

async def main():
    event = asyncio.Event()

    async def check_messages():
        while not event.is_set():
            # 检查是否有消息到达
            if has_messages():
                event.set()
            await asyncio.sleep(1)

    asyncio.create_task(check_messages())
    await fetch_data()
    event.set()  # 手动触发事件，打破循环

asyncio.run(main())