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

feat(connector.py): add Connector.running attribute

Browse Source
This commit is contained in:
Artur Borecki
2025-11-19 21:52:19 +01:00
parent fcaa7dae70
commit 99e94e2f5a
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/judas_client/connector.py
View File

@@ -54,6 +54,8 @@ class Connector:
self.inbound_buffer: bytes = b"" self.inbound_buffer: bytes = b""
self.outbound_buffer: bytes = b"" self.outbound_buffer: bytes = b""
self.running: bool = True
self.on_message: Callable[[Message], None] = on_message self.on_message: Callable[[Message], None] = on_message
def _send_outbound(self) -> None: def _send_outbound(self) -> None:
@@ -141,7 +143,7 @@ class Connector:
"""Run the main event loop.""" """Run the main event loop."""
self.connect() self.connect()
try: try:
while True: while self.running:
events = self.selector.select(timeout=1) events = self.selector.select(timeout=1)
for key, mask in events: for key, mask in events:
if mask & selectors.EVENT_READ: if mask & selectors.EVENT_READ: