diff --git a/docs/examples/asyncio_examples.ipynb b/docs/examples/asyncio_examples.ipynb index 5eab4db1f7..5029e907da 100644 --- a/docs/examples/asyncio_examples.ipynb +++ b/docs/examples/asyncio_examples.ipynb @@ -201,7 +201,7 @@ "\n", "async def reader(channel: redis.client.PubSub):\n", " while True:\n", - " message = await channel.get_message(ignore_subscribe_messages=True)\n", + " message = await channel.get_message(ignore_subscribe_messages=True, timeout=None)\n", " if message is not None:\n", " print(f\"(Reader) Message Received: {message}\")\n", " if message[\"data\"].decode() == STOPWORD:\n", @@ -264,7 +264,7 @@ "\n", "async def reader(channel: redis.client.PubSub):\n", " while True:\n", - " message = await channel.get_message(ignore_subscribe_messages=True)\n", + " message = await channel.get_message(ignore_subscribe_messages=True, timeout=None)\n", " if message is not None:\n", " print(f\"(Reader) Message Received: {message}\")\n", " if message[\"data\"].decode() == STOPWORD:\n",