PubSub example is not truly asyncIO

[Kuzey27]

The example for the subscriber in the PubSub system is not truly async and is using while True statement plus asyncio.sleep.
As you see the code is not waiting for notification from IO, instead, it is trying to check if there is a new message every 0.1 seconds.

async def reader(channel: aioredis.client.PubSub):
    while True:
        try:
            async with async_timeout.timeout(1):
                message = await channel.get_message(ignore_subscribe_messages=True)
                if message is not None:
                    print(f"(Reader) Message Received: {message}")
                    if message["data"] == STOPWORD:
                        print("(Reader) STOP")
                        break
                await asyncio.sleep(0.01)
        except asyncio.TimeoutError:
            pass

It can be replaced with the code below which is truly asyncIO.

async def reader(channel: aioredis.client.PubSub):
    async for message in channel.listen():
        print(f"(Reader) Message Received: {message}")
        if message["data"] == STOPWORD:
            print("(Reader) STOP")
            break