Skip to content

Conversation

DarkArc
Copy link

@DarkArc DarkArc commented Sep 5, 2025

No description provided.

@aaugustin
Copy link
Member

Thank you for the PR, it's a good starting point. The code requires a few changes (e.g. async for vs. for). I'll adjust it to make it work then merge.

@liuyangc3
Copy link

iter websocket should be async

async def consumer_handler(websocket):
-    for message in websocket:
+    async for message in websocket:
        await queue.put(message)

@DarkArc
Copy link
Author

DarkArc commented Sep 19, 2025

Yeah, I thought @aaugustin was going to fix that little bit based on his comment. Anyways, fixed and squashed.

@aaugustin
Copy link
Member

I intended to do it but didn't work on this projects for a few weeks :-|

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants