Skip to content

Conversation

@atorodotme
Copy link
Collaborator

No description provided.

Comment on lines 64 to 67
def on_channel_sdu(self, sdu):
async def handle_sdu():
await self.sdu_queue.put(sdu)

asyncio.create_task(handle_sdu())
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please use synchronized Queue instead:
https://docs.python.org/3/library/queue.html

Suggested change
def on_channel_sdu(self, sdu):
async def handle_sdu():
await self.sdu_queue.put(sdu)
asyncio.create_task(handle_sdu())
def on_channel_sdu(self, sdu):
self.sdu_queue.put_nowait(sdu)

@atorodotme atorodotme force-pushed the satoro/bumble_pandora_l2cap_receive branch from 88b3ae9 to 3ae19f3 Compare August 28, 2024 14:17
@zxzxwu zxzxwu reopened this Sep 1, 2025
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.

4 participants