From 8d06775c276089667d9bcdf679e89d9063834036 Mon Sep 17 00:00:00 2001 From: Artur Borecki Date: Sat, 30 Aug 2025 18:40:47 +0200 Subject: [PATCH] feat(connector.py): add `no_check_ack` arg to `send()` --- src/judas_client/connector.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/src/judas_client/connector.py b/src/judas_client/connector.py index 40a0c05..7f7ec53 100644 --- a/src/judas_client/connector.py +++ b/src/judas_client/connector.py @@ -98,12 +98,18 @@ class Connector: time.sleep(retry_interval) self.connect(retry_interval=min(30, retry_interval * 2)) - def send(self, data: bytes) -> None: + def send(self, data: bytes, no_check_ack: bool = False) -> None: self.logger.debug(f"[>] Sending data: {data}") while True: try: self.socket.sendall(data) - self.logger.info("[>] Data sent") + + if no_check_ack: + self.logger.debug("[>] Data sent without ACK check") + break + else: + self.logger.info("[>] Data sent") + acknowledged: bool = self._check_ack() if acknowledged: self.logger.debug("[.] Data acknowledged")