diff --git a/src/judas_client/connector.py b/src/judas_client/connector.py index 5c3b797..bab4346 100644 --- a/src/judas_client/connector.py +++ b/src/judas_client/connector.py @@ -68,6 +68,7 @@ class Connector: self.logger.debug( f"[>] Sent {sent} bytes: {self.outbound_buffer[:sent]!r}" ) + self.outbound_buffer = self.outbound_buffer[sent:] except BlockingIOError: # OS buffer full, wait for next EVENT_WRITE