reset heartbeat timeout when receiving any response from the server (#…

…208)
rabbitmq-community · Oct 2, 2024 · 55548c7 · 55548c7
1 parent 7bad17d
commit 55548c7
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/rstream/client.py b/rstream/client.py
@@ -272,6 +272,9 @@ async def _listener(self) -> None:
                 if not self.is_connection_alive():
                     break
 
+                # reset heartbeat time when we receive any response from the socket
+                self._last_heartbeat = time.monotonic()
+
                 logger.debug("Received frame: %s", frame)
 
                 _key = frame.key, frame.corr_id