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 +151 -144
2 changed files with 151 additions and 144 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 38d663a501 - Show all commits

4
src/judas_client/connector.py
View File

@@ -173,7 +173,7 @@ class Connector:
self.inbound_buffer.split(b"\n", 1)
)
try:
message = Message.from_bytes(message_bytes)
message: Message = Message.from_bytes(message_bytes)
# handle incoming ACKs
if (
message.category == Category.CONTROL
@@ -192,7 +192,7 @@ class Connector:
self.on_message(message)
if message.ack_required:
ack_message = Message.ack(message.id)
ack_message: Message = Message.ack(message.id)
self.send(ack_message)
self._send_outbound()
except Exception as e: