judas/judas_client
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

refactor: make connector use queues #4

Merged
pufereq merged 12 commits from refactor/make-connector-use-queues into develop 2025-11-30 17:35:33 +00:00
Conversation 0 Commits 12 Files Changed 2 +150 -145
2 changed files with 150 additions and 145 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit a28c724145 - Show all commits

1
src/judas_client/connector.py
View File

@@ -68,6 +68,7 @@ class Connector:
self.logger.debug( self.logger.debug(
f"[>] Sent {sent} bytes: {self.outbound_buffer[:sent]!r}" f"[>] Sent {sent} bytes: {self.outbound_buffer[:sent]!r}"
) )
self.outbound_buffer = self.outbound_buffer[sent:] self.outbound_buffer = self.outbound_buffer[sent:]
except BlockingIOError: except BlockingIOError:
# OS buffer full, wait for next EVENT_WRITE # OS buffer full, wait for next EVENT_WRITE