We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent efb7512 commit e7281e3Copy full SHA for e7281e3
1 file changed
docs/howto/patterns.rst
@@ -98,7 +98,7 @@ messages at one, an in-process queue can be leveraged::
98
queue = asyncio.Queue(MAX_WORKERS)
99
100
async def consumer_handler(websocket):
101
- for message in websocket:
+ async for message in websocket:
102
await queue.put(message)
103
104
async def worker(websocket):
0 commit comments